spring:
kafka:
template:
# 当使用 kafkaTemplate 的 sendDefault 方法的时候,使用的是这里配置的 topic
defaultTopic: topic-1
# partition-num 和 replication-num KafkaProperties 没有提供配置的地方
bootstrap-servers: 127.0.0.1:9092
producer:
retries: 3
key-serializer: org.apache.kafka.common.serialization.StringSerializer
value-serializer: org.apache.kafka.common.serialization.StringSerializer
consumer:
# @KafkaListener 中不指定 group-id 使用这边 groupId,这边也不指定项目就报错起不来,指定了就覆盖这边的
# group-id: test
key-deserializer: org.apache.kafka.common.serialization.StringDeserializer
value-deserializer: org.apache.kafka.common.serialization.StringDeserializer
# 消息读取方式
auto-offset-reset: latest
# auto-offset-reset: earliest
# 手动提交
enable-auto-commit: false
标签:auto,配置,kafka,common,serialization,apache,org,yml From: https://www.cnblogs.com/xxsdnol/p/17816751.html