producer.properties
Kafka生产者参数配置,具体参数说明参考Kafka文档。
文件 | 说明 |
---|---|
bootstrap.servers=ip1:port1,ip2:port2,ip3:port3 | Kafka 连接信息按需配置 |
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 | 必须保持默认 |