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

fix(test): make strings json-friendly in kafka testsuite

This commit is contained in:
Andrew Mayorov 2023-02-24 15:05:20 +03:00
parent de740a2fd9
commit 9cbe64a132
No known key found for this signature in database
GPG Key ID: 2837C62ACFBFED5D
1 changed files with 2 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
lib-ee/emqx_ee_bridge/test/emqx_bridge_impl_kafka_producer_SUITE.erl
View File

@ -268,7 +268,7 @@ kafka_bridge_rest_api_helper(Config) ->
CreateBodyTmp = #{ CreateBodyTmp = #{
<<"type">> => <<"kafka">>, <<"type">> => <<"kafka">>,
<<"name">> => <<"my_kafka_bridge">>, <<"name">> => <<"my_kafka_bridge">>,
<<"bootstrap_hosts">> => maps:get(<<"bootstrap_hosts">>, Config), <<"bootstrap_hosts">> => iolist_to_binary(maps:get(<<"bootstrap_hosts">>, Config)),
<<"enable">> => true, <<"enable">> => true,
<<"authentication">> => maps:get(<<"authentication">>, Config), <<"authentication">> => maps:get(<<"authentication">>, Config),
<<"producer">> => #{ <<"producer">> => #{
@ -276,7 +276,7 @@ kafka_bridge_rest_api_helper(Config) ->
topic => <<"t/#">> topic => <<"t/#">>
}, },
<<"kafka">> => #{ <<"kafka">> => #{
<<"topic">> => erlang:list_to_binary(KafkaTopic), <<"topic">> => iolist_to_binary(KafkaTopic),
<<"buffer">> => #{ <<"buffer">> => #{
<<"memory_overload_protection">> => <<"false">> <<"memory_overload_protection">> => <<"false">>
}, },