Skip to content

producer.properties

Kafka生产者参数配置,具体参数说明参考Kafka文档

表1 生产者参数配置信息
文件说明
bootstrap.servers=ip1:port1,ip2:port2,ip3:port3Kafka 连接信息按需配置
compression.type=none建议保持默认
linger.ms=10建议保持默认
acks=all建议保持默认
retries=8建议保持默认
batch.size=163840建议保持默认
buffer.memory=33554432建议保持默认
enable.idempotence=true建议保持默认
key.serializer=org.apache.kafka.common.serialization.StringSerializer必须保持默认
value.serializer=org.apache.kafka.common.serialization.ByteArraySerializer必须保持默认
partitioner.class=com.sync.util.BinlogPartitioner必须保持默认