poll.properties
pollbinlog工具从Kafka提取数据使用的消费者配置文件。
文件 | 说明 |
---|---|
bootstrap.servers=ip1:port1,ip2:port2,ip3:port3 | Kafka 连接信息按需配置 |
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 | 必须保持默认 |