consumer.properties
Kafka消费者参数配置,具体参数说明参考Kafka文档。
文件 | 说明 |
---|---|
bootstrap.servers=ip1:port1,ip2:port2,ip3:port3 | Kafka 连接信息按需配置 |
group.id=getendpos | 建议保持默认 |
auto.offset.reset=earliest | 建议保持默认 |
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 | 必须保持默认 |