Skip to content

poll.properties

pollbinlog工具从Kafka提取数据使用的消费者配置文件。

文件说明
bootstrap.servers=ip1:port1,ip2:port2,ip3:port3Kafka 连接信息按需配置
group.id=getendpos建议保持默认
auto.offset.reset=pollsql建议保持默认
enable.auto.commit=false建议保持默认
auto.commit.interval.ms=1000建议保持默认
session.timeout.ms=30000建议保持默认
max.partition.fetch.bytes=10485760建议保持默认
max.poll.records=10建议保持默认
max.poll.interval.ms=300000建议保持默认
key.deserializer=org.apache.kafka.common.serialization.StringDeserializer必须保持默认
value.deserializer=org.apache.kafka.common.serialization.ByteArrayDeserializer必须保持默认