From 0587e0d3f3b6e3b2ee25ce0bfd863bf5f49910bf Mon Sep 17 00:00:00 2001 From: Thales Macedo Garitezi Date: Tue, 14 Mar 2023 18:16:08 -0300 Subject: [PATCH] refactor(kafka_consumer): change the generated consumer group id Co-authored-by: Zaiming (Stone) Shi --- .../src/kafka/emqx_bridge_impl_kafka_consumer.erl | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/lib-ee/emqx_ee_bridge/src/kafka/emqx_bridge_impl_kafka_consumer.erl b/lib-ee/emqx_ee_bridge/src/kafka/emqx_bridge_impl_kafka_consumer.erl index 6abd3ed02..44633213c 100644 --- a/lib-ee/emqx_ee_bridge/src/kafka/emqx_bridge_impl_kafka_consumer.erl +++ b/lib-ee/emqx_ee_bridge/src/kafka/emqx_bridge_impl_kafka_consumer.erl @@ -432,7 +432,7 @@ log_when_error(Fun, Log) -> -spec consumer_group_id(atom() | binary()) -> binary(). consumer_group_id(BridgeName0) -> BridgeName = to_bin(BridgeName0), - <<"emqx-kafka-consumer:", BridgeName/binary>>. + <<"emqx-kafka-consumer-", BridgeName/binary>>. -spec is_dry_run(manager_id()) -> boolean(). is_dry_run(InstanceId) ->