chore: adjust

README.md

@@ -22,8 +22,8 @@ _build/default/emqx_plugrel/emqx_plugin_kafka-<vsn>.tar.gz
 plugin_kafka {
   // required
   connection {
-    // Kafka client id.
-    // optional   default:client
+    // Kafka client id: "emqx_plugin:kafka_client:${client_id}"
+    // optional   default:"emqx_plugin:kafka_client:emqx_plugin_kafka_connection"
     client_id = "kafka_client"
     // Kafka address.
     // required

src/emqx_plugin_kafka_hook.erl

@@ -232,8 +232,10 @@ query(
     EvtMsg,
     #{channel_id := ChannelId}
 ) ->
-    Ret = emqx_resource:query(emqx_plugin_kafka_util:resource_id(), {ChannelId, EvtMsg}),
-    query_ret(Ret, EvtMsg).
+    query_ret(
+        emqx_resource:query(emqx_plugin_kafka_util:resource_id(), {ChannelId, EvtMsg}),
+        EvtMsg
+    ).
 
 query_ret({_, {ok, _}}, _) ->
     ok;

src/emqx_plugin_kafka_producer.erl

@@ -19,8 +19,6 @@
     , on_query_async/4
 ]).
 
--include_lib("emqx/include/logger.hrl").
-
 query_mode(_) ->
     simple_async_internal_buffer.