yuanbiao
/
emqx
1
0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

test: fix emqx_bridge_v2_kafka_producer_SUITE

This commit is contained in:
Ivan Dyachkov 2023-10-26 19:59:00 +02:00 committed by Zaiming (Stone) Shi
parent 89812f0a7a
commit 7745cb8ef7
1 changed files with 6 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

7
apps/emqx_bridge_kafka/test/emqx_bridge_v2_kafka_producer_SUITE.erl
View File

@ -212,7 +212,7 @@ bridge_v2_config(ConnectorName) ->
connector_config() -> connector_config() ->
#{ #{
<<"authentication">> => <<"none">>, <<"authentication">> => <<"none">>,
<<"bootstrap_hosts">> => <<"127.0.0.1:9092">>, <<"bootstrap_hosts">> => iolist_to_binary(kafka_hosts_string()),
<<"connect_timeout">> => <<"5s">>, <<"connect_timeout">> => <<"5s">>,
<<"enable">> => true, <<"enable">> => true,
<<"metadata_request_timeout">> => <<"5s">>, <<"metadata_request_timeout">> => <<"5s">>,
@ -236,3 +236,8 @@ connector_config() ->
<<"versions">> => [<<"tlsv1.3">>, <<"tlsv1.2">>] <<"versions">> => [<<"tlsv1.3">>, <<"tlsv1.2">>]
} }
}. }.
kafka_hosts_string() ->
KafkaHost = os:getenv("KAFKA_PLAIN_HOST", "kafka-1.emqx.net"),
KafkaPort = os:getenv("KAFKA_PLAIN_PORT", "9092"),
KafkaHost ++ ":" ++ KafkaPort.