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) ->