fix(emqx_connector_info): refactoring based on thalesmg's comments

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,

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
+    ).

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(

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, []},

apps/emqx_bridge_kafka/src/emqx_bridge_kafka_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).
 

apps/emqx_bridge_kafka/src/emqx_bridge_kafka_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).
 

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,