关于max.poll.record和fetch.max.bytes

Consumer读取partition中的数据是通过调用发起一个fetch请求来执行的。而从KafkaConsumer来看，它有一个poll方法。但是这个poll方法只是可能会发起fetch请求。原因是：Consumer每次发起fetch请求时，读取到的数据是有限制的，通过配置项max.partition.fetch.bytes来限制的。而在执行poll方法时，会根据配置项个max.poll.records来限制一次最多pool多少个record。

那么就可能出现这样的情况： 在满足max.partition.fetch.bytes限制的情况下，假如fetch到了100个record，放到本地缓存后，由于max.poll.records限制每次只能poll出15个record。那么KafkaConsumer就需要执行7次才能将这一次通过网络发起的fetch请求所fetch到的这100个record消费完毕。其中前6次是每次pool中15个record，最后一次是poll出10个record。

关于session.timeout.ms、heartbeat.interval.ms和max.poll.interval.ms

Kafka引入了独立的心跳线程，可以在轮询消息的空档发送心跳。这样依赖，发送心跳的频率与消息轮询的频率之间相互独立。但是会出现活锁问题，活锁：消费者发送心跳，但并没有poll数据。
这种情况 通过session.timeout.ms和max.poll.interval.ms避免发生活锁，如果长时间没有poll，会认为消费者失效，触发rebalance。