diff --git a/apps/emqx_bridge_kafka/test/emqx_bridge_kafka_tests.erl b/apps/emqx_bridge_kafka/test/emqx_bridge_kafka_tests.erl index f476ded39..395761d48 100644 --- a/apps/emqx_bridge_kafka/test/emqx_bridge_kafka_tests.erl +++ b/apps/emqx_bridge_kafka/test/emqx_bridge_kafka_tests.erl @@ -139,6 +139,7 @@ kafka_consumer_test() -> ok. message_key_dispatch_validations_test() -> + Name = myproducer, Conf0 = kafka_producer_new_hocon(), Conf1 = Conf0 ++ @@ -155,7 +156,7 @@ message_key_dispatch_validations_test() -> <<"message">> := #{<<"key">> := <<>>} } }, - emqx_utils_maps:deep_get([<<"bridges">>, <<"kafka">>, <<"myproducer">>], Conf) + emqx_utils_maps:deep_get([<<"bridges">>, <<"kafka">>, atom_to_binary(Name)], Conf) ), ?assertThrow( {_, [ @@ -166,8 +167,6 @@ message_key_dispatch_validations_test() -> ]}, check(Conf) ), - %% ensure atoms exist - _ = [myproducer], ?assertThrow( {_, [ #{ diff --git a/apps/emqx_bridge_pulsar/test/emqx_bridge_pulsar_tests.erl b/apps/emqx_bridge_pulsar/test/emqx_bridge_pulsar_tests.erl index 031767063..7169ea3d2 100644 --- a/apps/emqx_bridge_pulsar/test/emqx_bridge_pulsar_tests.erl +++ b/apps/emqx_bridge_pulsar/test/emqx_bridge_pulsar_tests.erl @@ -11,6 +11,7 @@ %%=========================================================================== pulsar_producer_validations_test() -> + Name = my_producer, Conf0 = pulsar_producer_hocon(), Conf1 = Conf0 ++ @@ -24,7 +25,7 @@ pulsar_producer_validations_test() -> <<"strategy">> := <<"key_dispatch">>, <<"message">> := #{<<"key">> := <<>>} }, - emqx_utils_maps:deep_get([<<"bridges">>, <<"pulsar_producer">>, <<"my_producer">>], Conf) + emqx_utils_maps:deep_get([<<"bridges">>, <<"pulsar_producer">>, atom_to_binary(Name)], Conf) ), ?assertThrow( {_, [ @@ -35,8 +36,6 @@ pulsar_producer_validations_test() -> ]}, check(Conf) ), - %% ensure atoms exist - _ = [my_producer], ?assertThrow( {_, [ #{