Spring boot kafka执行多次多次消费
Spring boot kafka执行多次多次消费试试注释掉retries 失败后重复发送次数max-partitton-fetch-byte 发送最大消息auto-commit-interval 间隔kafka:bootstrap-servers: 127.0.0.1:9092 #指定kafka server的地址,集群配多个,中间,逗号隔开producer:key-serializer: or
·
Spring boot kafka执行多次多次消费
试试注释掉
retries 失败后重复发送次数
max-partitton-fetch-byte 发送最大消息
auto-commit-interval 间隔
kafka:
bootstrap-servers: 127.0.0.1:9092 #指定kafka server的地址,集群配多个,中间,逗号隔开
producer:
key-serializer: org.apache.kafka.common.serialization.StringSerializer #发送key的类型
value-serializer: org.apache.kafka.common.serialization.ByteArraySerializer #发送value的类型
# retries: 1 #失败后重复发送次数
consumer:
group-id: default_consumer_group #群组ID
enable-auto-commit: false #停止(取消)自动发送
# max-partitton-fetch-byte: 15728640 #发送最大消息
# auto-commit-interval: 1000 #间隔
key-deserializer: org.apache.kafka.common.serialization.StringDeserializer #接收key的类型
value-deserializer: org.apache.kafka.common.serialization.ByteArrayDeserializer #接收value的类型
其他步骤
更多推荐
已为社区贡献11条内容
所有评论(0)