From 1bad32b991af8ef9795e27873498a5f88cf449e0 Mon Sep 17 00:00:00 2001 From: anlicheng <244108715@qq.com> Date: Wed, 10 Sep 2025 11:13:14 +0800 Subject: [PATCH] fix kafka --- apps/iot/src/endpoint/endpoint_sup.erl | 12 +++++++----- 1 file changed, 7 insertions(+), 5 deletions(-) diff --git a/apps/iot/src/endpoint/endpoint_sup.erl b/apps/iot/src/endpoint/endpoint_sup.erl index ae6ff02..c8bd065 100644 --- a/apps/iot/src/endpoint/endpoint_sup.erl +++ b/apps/iot/src/endpoint/endpoint_sup.erl @@ -52,11 +52,13 @@ kafka_test() -> title = <<"kafka测试"/utf8>>, %% 配置项, 格式: #{<<"protocol">> => <<"http|https|ws|kafka|mqtt">>, <<"args">> => #{}} config = #kafka_endpoint{ - sasl_config = { - scram_sha_256, - <<"admin">>, - <<"lz4rP5UavRTiGZEZK8G51mxHcM5iPC">> - }, + %sasl_config = { + % scram_sha_256, + % <<"admin">>, + % <<"lz4rP5UavRTiGZEZK8G51mxHcM5iPC">> + %}, + + sasl_config = undefined, bootstrap_servers = [ {"127.0.0.1", 19092}