fix kafka

This commit is contained in:
anlicheng 2025-09-10 11:13:14 +08:00
parent 60a3fe9af4
commit 1bad32b991

View File

@ -52,11 +52,13 @@ kafka_test() ->
title = <<"kafka测试"/utf8>>, title = <<"kafka测试"/utf8>>,
%% , : #{<<"protocol">> => <<"http|https|ws|kafka|mqtt">>, <<"args">> => #{}} %% , : #{<<"protocol">> => <<"http|https|ws|kafka|mqtt">>, <<"args">> => #{}}
config = #kafka_endpoint{ config = #kafka_endpoint{
sasl_config = { %sasl_config = {
scram_sha_256, % scram_sha_256,
<<"admin">>, % <<"admin">>,
<<"lz4rP5UavRTiGZEZK8G51mxHcM5iPC">> % <<"lz4rP5UavRTiGZEZK8G51mxHcM5iPC">>
}, %},
sasl_config = undefined,
bootstrap_servers = [ bootstrap_servers = [
{"127.0.0.1", 19092} {"127.0.0.1", 19092}