kafka动态分组（保证每条信息每个运营模块都会消费）

2025-11-13 13:10:22 +08:00 · 2025-11-13 13:10:22 +08:00 · 8c06e99f10
commit 8c06e99f10
parent 9a7292be7b
1 changed files with 1 additions and 1 deletions
--- a/ebike-operations/src/main/resources/application-dev.yml
+++ b/ebike-operations/src/main/resources/application-dev.yml
@ -15,7 +15,7 @@ spring:
      key-serializer: org.apache.kafka.common.serialization.StringSerializer
      value-serializer: org.apache.kafka.common.serialization.StringSerializer
    consumer:
-      group-id: gather-group-${random.uuid}
+      group-id: operations-group-${random.uuid}
      key-deserializer: org.apache.kafka.common.serialization.StringDeserializer
      value-deserializer: org.apache.kafka.common.serialization.StringDeserializer
    listener: