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

fix: use different instance id in Kafka auth test

This commit is contained in:
Kjell Winblad 2022-09-15 07:33:07 +02:00
parent 5820b028cb
commit 4dc26eeba7
1 changed files with 6 additions and 7 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

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

@ -28,8 +28,7 @@ init_per_suite(Config) ->
end_per_suite(_) -> end_per_suite(_) ->
ok. ok.
do_publish(Conf, KafkaTopic) -> do_publish(Conf, KafkaTopic, InstId) ->
InstId = <<"InstanceID">>,
Time = erlang:system_time(millisecond), Time = erlang:system_time(millisecond),
BinTime = integer_to_binary(Time), BinTime = integer_to_binary(Time),
Msg = #{ Msg = #{
@ -53,7 +52,7 @@ t_publish(_CtConfig) ->
"kafka_hosts_string" => kafka_hosts_string(), "kafka_hosts_string" => kafka_hosts_string(),
"kafka_topic" => KafkaTopic "kafka_topic" => KafkaTopic
}), }),
do_publish(Conf, KafkaTopic). do_publish(Conf, KafkaTopic, <<"NoAuthInst">>).
t_publish_sasl_plain(_CtConfig) -> t_publish_sasl_plain(_CtConfig) ->
KafkaTopic = "test-topic-one-partition", KafkaTopic = "test-topic-one-partition",
@ -66,7 +65,7 @@ t_publish_sasl_plain(_CtConfig) ->
"kafka_hosts_string" => kafka_hosts_string_sasl(), "kafka_hosts_string" => kafka_hosts_string_sasl(),
"kafka_topic" => KafkaTopic "kafka_topic" => KafkaTopic
}), }),
do_publish(Conf, KafkaTopic). do_publish(Conf, KafkaTopic, <<"SASLPlainInst">>).
t_publish_sasl_scram256(_CtConfig) -> t_publish_sasl_scram256(_CtConfig) ->
KafkaTopic = "test-topic-one-partition", KafkaTopic = "test-topic-one-partition",
@ -79,7 +78,7 @@ t_publish_sasl_scram256(_CtConfig) ->
"kafka_hosts_string" => kafka_hosts_string_sasl(), "kafka_hosts_string" => kafka_hosts_string_sasl(),
"kafka_topic" => KafkaTopic "kafka_topic" => KafkaTopic
}), }),
do_publish(Conf, KafkaTopic). do_publish(Conf, KafkaTopic, <<"SASLScram256Inst">>).
t_publish_sasl_scram512(_CtConfig) -> t_publish_sasl_scram512(_CtConfig) ->
KafkaTopic = "test-topic-one-partition", KafkaTopic = "test-topic-one-partition",
@ -92,7 +91,7 @@ t_publish_sasl_scram512(_CtConfig) ->
"kafka_hosts_string" => kafka_hosts_string_sasl(), "kafka_hosts_string" => kafka_hosts_string_sasl(),
"kafka_topic" => KafkaTopic "kafka_topic" => KafkaTopic
}), }),
do_publish(Conf, KafkaTopic). do_publish(Conf, KafkaTopic, <<"SASLScram512Inst">>).
t_publish_sasl_kerberos(_CtConfig) -> t_publish_sasl_kerberos(_CtConfig) ->
KafkaTopic = "test-topic-one-partition", KafkaTopic = "test-topic-one-partition",
@ -104,7 +103,7 @@ t_publish_sasl_kerberos(_CtConfig) ->
"kafka_hosts_string" => kafka_hosts_string_sasl(), "kafka_hosts_string" => kafka_hosts_string_sasl(),
"kafka_topic" => KafkaTopic "kafka_topic" => KafkaTopic
}), }),
do_publish(Conf, KafkaTopic). do_publish(Conf, KafkaTopic, <<"SASLKerberosInst">>).
config(Args) -> config(Args) ->
{ok, Conf} = hocon:binary(hocon_config(Args)), {ok, Conf} = hocon:binary(hocon_config(Args)),