- 功能说明/问题现象: 将kafka的依赖库从ekaf替换为brod，修改初始化逻辑

- 代码提交人: ultrakid
- 自测报告:
- 软件开发号:
- 来源项目编号/版本简称:
- 问题分类:
- 方案/解决办法:
- 有无兼容性问题:
- 有无配合更新模块:
- 需求路径:
- BUG路径:
- 设计文档路径:
- 建议:
- 代码审核人:

src/emqx_plugin_kafka.app.src

@@ -3,7 +3,7 @@
   {vsn, "git"},
   {modules, []},
   {registered, [emqx_plugin_kafka_sup]},
-  {applications, [kernel,stdlib]},
+  {applications, [kernel,stdlib, brod]},
   {mod, {emqx_plugin_kafka_app,[]}},
   {env, []},
   {licenses, ["Apache-2.0"]},

src/emqx_plugin_kafka.erl

@@ -261,7 +261,7 @@ on_session_terminated(_ClientInfo = #{clientid := ClientId}, Reason, SessInfo, _
   ok.
 
 kafka_init(_Env) ->
-  ?LOG_INFO("Start to init emqx plugin kafka.....~n"),
+  ?LOG_INFO("Start to init emqx plugin kafka..... ~n"),
   {ok, AddressList} = application:get_env(emqx_plugin_kafka, kafka_address_list),
   ?LOG_INFO("[KAFKA PLUGIN]KafkaAddressList = ~p~n", [AddressList]),
   {ok, KafkaConfig} = application:get_env(emqx_plugin_kafka, kafka_config),