SpringBoot Kafka生产者 多kafka配置

生产者 多kafka配置"/>

SpringBoot Kafka生产者 多kafka配置

一、配置文件

xxxxxx:kafka:bootstrap-servers: xx.xx.xx.xx:9092,xx.xx.xx.xx:9092producer: # 设置大于0的值，则客户端会将发送失败的记录重新发送retries: 3 #当有多个消息需要被发送到同一个分区时，生产者会把它们放在同一个批次里。该参数指定了一个批次可以使用的内存大小，按照字节数计算。16Mbatch-size: 16384linger: 1# 设置生产者内存缓冲区的大小。#32Mbuffer-memory: 33554432# acks=0 ： 生产者在成功写入消息之前不会等待任何来自服务器的响应。# acks=1 ： 只要集群的首领节点收到消息，生产者就会收到一个来自服务器成功响应。# acks=all ：只有当所有参与复制的节点全部收到消息时，生产者才会收到一个来自服务器的成功响应。acks: 1# 指定消息key和消息体的编解码方式 值的序列化方式key-serializer: org.apache.kafkamon.serialization.StringSerializervalue-serializer: org.apache.kafkamon.serialization.StringSerializerconsumer:poll-timeout: 3000key-deserializer: org.apache.kafkamon.serialization.StringDeserializervalue-deserializer: org.apache.kafkamon.serialization.StringDeserializerauto-commit: