版本0.10.0.0
bootstrap.servers
key.deserializer
value.deserializer
group.id:一个group id区分一个group
heartbeat.interval.ms :comsumer只有在poll才会发心跳包,因为poll后还要处理数据,这个值最好是session.timeout.ms的三分之一
session.timeout.ms:超过该值,则认为该消费者client已经出故障,进行balance
(这两个设置,不好限制处理消息的时间。在kafka0.10.1之后的版本中,kafka consumer是一个是heartbeat 线程,另一个是processing线程,添加max.poll.interval.ms,两次Poll之间最大时间,就是处理消息最长时间,这样更好限制处理消息的时间,并规定 max.poll.interval.ms必须大于session.timeout.ms)
request.timeout.ms:
fetch.max.wait.ms:在服务端等待最大时间
fetch.min.bytes:最小fetch字节
auto.commit.interval.ms:
max.partition.fetch.bytes
auto.offset.reset:
connections.max.idle.ms:连接闲置时间
enable.auto.commit:是否自动commit
exclude.internal.topics:内部topic是否可以暴露给comsumer()
max.poll.records:
partition.assignment.strategy:分配策略range,roundrobin
receive.buffer.bytes:
send.buffer.bytes
check.crcs
client.id
interceptor.classes