问题现象
Kafka消费组时不时就会断开连接,提示如下异常
2019-19-28 12:36:44.711 |-INFO [kafka-coordinator-heartbeat-thread | loongshawn] org.apache.kafka.clients.consumer.internals.AbstractCoordinator [1234] -| [Consumer clientId=loongshawn-xxxxxxxxxxxxxxxxxxxxxxxxxxxxx-127.0.0.1, groupId=loongshawn] Member loongshawn-xxxxxxxxxxxxxxxxxxxxxxxxxxxxx-127.0.0.1 sending LeaveGroup request to coordinator xx.xx.xx.xx:9092 (id: 23456223346 rack: null) due to consumer poll timeout has expired. This means the time between subsequent calls to poll() was longer than the configured max.poll.interval.ms, which typically implies that the poll loop is spending too much time processing messages. You can address this either by increasing max.poll.interval.ms or by reducing the maximum size o
2019-19-28 12:36:44.711 |-INFO [kafka-coordinator-heartbeat-thread | loongshawn] org.apache.kafka.clients.consumer.internals.AbstractCoordinator [1234] -| [Consumer clientId=loongshawn-xxxxxxxxxxxxxxxxxxxxxxxxxxxxx-127.0.0.1, groupId=loongshawn] Member loongshawn-xxxxxxxxxxxxxxxxxxxxxxxxxxxxx-127.0.0.1 sending LeaveGroup request to coordinator xx.xx.xx.xx:9092 (id: 23456223346 rack: null) due to consumer poll timeout has expired. This means the time between subsequent calls to poll() was longer than the configured max.poll.interval.ms, which typically implies that the poll loop is spending too much time processing messages. You can address this either by increasing max.poll.interval.ms or by reducing the maximum size o