Skip to content

consumer.properties

Kafka消费者参数配置,具体参数说明参考Kafka文档

文件说明
bootstrap.servers=ip1:port1,ip2:port2,ip3:port3Kafka 连接信息按需配置
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 必须保持默认