attiya/ebike-plus
SHA256
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

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

Browse Source
This commit is contained in:
attiya 2025-11-13 13:04:21 +08:00
parent fe5766db35
commit 9a7292be7b
1 changed files with 1 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
ebike-operations/src/main/resources/application-dev.yml
View File

@ -15,7 +15,7 @@ spring:
key-serializer: org.apache.kafka.common.serialization.StringSerializer key-serializer: org.apache.kafka.common.serialization.StringSerializer
value-serializer: org.apache.kafka.common.serialization.StringSerializer value-serializer: org.apache.kafka.common.serialization.StringSerializer
consumer: consumer:
group-id: gather-group group-id: gather-group-${random.uuid}
key-deserializer: org.apache.kafka.common.serialization.StringDeserializer key-deserializer: org.apache.kafka.common.serialization.StringDeserializer
value-deserializer: org.apache.kafka.common.serialization.StringDeserializer value-deserializer: org.apache.kafka.common.serialization.StringDeserializer
listener: listener: