diff --git a/apps/emqx_bridge/src/emqx_action_info.erl b/apps/emqx_bridge/src/emqx_action_info.erl
index c6282fc18..464b2e429 100644
--- a/apps/emqx_bridge/src/emqx_action_info.erl
+++ b/apps/emqx_bridge/src/emqx_action_info.erl
@@ -91,7 +91,7 @@ hard_coded_action_info_modules_ee() ->
         emqx_bridge_dynamo_action_info,
         emqx_bridge_gcp_pubsub_consumer_action_info,
         emqx_bridge_gcp_pubsub_producer_action_info,
-        emqx_bridge_kafka_action_info,
+        emqx_bridge_kafka_producer_action_info,
         emqx_bridge_kafka_consumer_action_info,
         emqx_bridge_kinesis_action_info,
         emqx_bridge_hstreamdb_action_info,
diff --git a/apps/emqx_bridge_azure_event_hub/src/emqx_bridge_azure_event_hub_action_info.erl b/apps/emqx_bridge_azure_event_hub/src/emqx_bridge_azure_event_hub_action_info.erl
index 4361a3bee..6c472b479 100644
--- a/apps/emqx_bridge_azure_event_hub/src/emqx_bridge_azure_event_hub_action_info.erl
+++ b/apps/emqx_bridge_azure_event_hub/src/emqx_bridge_azure_event_hub_action_info.erl
@@ -24,9 +24,11 @@ connector_type_name() -> azure_event_hub_producer.
 schema_module() -> emqx_bridge_azure_event_hub.
 
 connector_action_config_to_bridge_v1_config(ConnectorConfig, ActionConfig) ->
-    emqx_bridge_kafka_action_info:connector_action_config_to_bridge_v1_config(
+    emqx_bridge_kafka_producer_action_info:connector_action_config_to_bridge_v1_config(
         ConnectorConfig, ActionConfig
     ).
 
 bridge_v1_config_to_action_config(BridgeV1Conf, ConnectorName) ->
-    emqx_bridge_kafka_action_info:bridge_v1_config_to_action_config(BridgeV1Conf, ConnectorName).
+    emqx_bridge_kafka_producer_action_info:bridge_v1_config_to_action_config(
+        BridgeV1Conf, ConnectorName
+    ).
diff --git a/apps/emqx_bridge_es/src/emqx_bridge_es_connector_info.erl b/apps/emqx_bridge_es/src/emqx_bridge_es_connector_info.erl
index 4542c9382..4fe507047 100644
--- a/apps/emqx_bridge_es/src/emqx_bridge_es_connector_info.erl
+++ b/apps/emqx_bridge_es/src/emqx_bridge_es_connector_info.erl
@@ -35,7 +35,7 @@ config_schema() ->
         )}.
 
 schema_module() ->
-    emqx_bridge_azure_event_hub.
+    emqx_bridge_es_connector.
 
 api_schema(Method) ->
     emqx_connector_schema:api_ref(
diff --git a/apps/emqx_bridge_kafka/src/emqx_bridge_kafka.app.src b/apps/emqx_bridge_kafka/src/emqx_bridge_kafka.app.src
index 90ac23e81..34b8dfa06 100644
--- a/apps/emqx_bridge_kafka/src/emqx_bridge_kafka.app.src
+++ b/apps/emqx_bridge_kafka/src/emqx_bridge_kafka.app.src
@@ -14,12 +14,12 @@
     ]},
     {env, [
         {emqx_action_info_modules, [
-            emqx_bridge_kafka_action_info,
+            emqx_bridge_kafka_producer_action_info,
             emqx_bridge_kafka_consumer_action_info
         ]},
         {emqx_connector_info_modules, [
             emqx_bridge_kafka_consumer_connector_info,
-            emqx_bridge_kafka_connector_info
+            emqx_bridge_kafka_producer_connector_info
         ]}
     ]},
     {modules, []},
diff --git a/apps/emqx_bridge_kafka/src/emqx_bridge_kafka_action_info.erl b/apps/emqx_bridge_kafka/src/emqx_bridge_kafka_producer_action_info.erl
similarity index 97%
rename from apps/emqx_bridge_kafka/src/emqx_bridge_kafka_action_info.erl
rename to apps/emqx_bridge_kafka/src/emqx_bridge_kafka_producer_action_info.erl
index 2c7810028..37a061072 100644
--- a/apps/emqx_bridge_kafka/src/emqx_bridge_kafka_action_info.erl
+++ b/apps/emqx_bridge_kafka/src/emqx_bridge_kafka_producer_action_info.erl
@@ -2,7 +2,7 @@
 %% Copyright (c) 2022-2024 EMQ Technologies Co., Ltd. All Rights Reserved.
 %%--------------------------------------------------------------------
 
--module(emqx_bridge_kafka_action_info).
+-module(emqx_bridge_kafka_producer_action_info).
 
 -behaviour(emqx_action_info).
 
diff --git a/apps/emqx_bridge_kafka/src/emqx_bridge_kafka_connector_info.erl b/apps/emqx_bridge_kafka/src/emqx_bridge_kafka_producer_connector_info.erl
similarity index 95%
rename from apps/emqx_bridge_kafka/src/emqx_bridge_kafka_connector_info.erl
rename to apps/emqx_bridge_kafka/src/emqx_bridge_kafka_producer_connector_info.erl
index d0b013cc3..e320a42c6 100644
--- a/apps/emqx_bridge_kafka/src/emqx_bridge_kafka_connector_info.erl
+++ b/apps/emqx_bridge_kafka/src/emqx_bridge_kafka_producer_connector_info.erl
@@ -2,7 +2,7 @@
 %% Copyright (c) 2022-2024 EMQ Technologies Co., Ltd. All Rights Reserved.
 %%--------------------------------------------------------------------
 
--module(emqx_bridge_kafka_connector_info).
+-module(emqx_bridge_kafka_producer_connector_info).
 
 -behaviour(emqx_connector_info).
 
diff --git a/apps/emqx_connector/src/emqx_connector_info.erl b/apps/emqx_connector/src/emqx_connector_info.erl
index 25039dee7..766f34168 100644
--- a/apps/emqx_connector/src/emqx_connector_info.erl
+++ b/apps/emqx_connector/src/emqx_connector_info.erl
@@ -81,7 +81,7 @@ hard_coded_connector_info_modules_ee() ->
         emqx_bridge_gcp_pubsub_producer_connector_info,
         emqx_bridge_hstreamdb_connector_info,
         emqx_bridge_kafka_consumer_connector_info,
-        emqx_bridge_kafka_connector_info,
+        emqx_bridge_kafka_producer_connector_info,
         emqx_bridge_kinesis_connector_info,
         emqx_bridge_matrix_connector_info,
         emqx_bridge_pgsql_connector_info,