0

我正在使用 confluent-kafka 1.8.2。面临一个问题，在 N 条消息之后，消费者因错误而崩溃。

GroupCoordinator/5：飞行中的 OffsetCommitRequest 超时（60165 毫秒后，超时 #0）

请帮助我了解问题所在以及如何解决。我使用具有以下参数的消费者：

'enable.auto.commit': True,
'auto.offset.reset': 'earliest',
'sasl.mechanism': 'SCRAM-SHA-512',
'heartbeat.interval.ms': 3000,
'max.poll.interval.ms': 300000,
'session.timeout.ms': 300000

    try:
    while True:
        msg = consumer.poll()
        if msg is None:
            continue
        if msg.error():
            logger.exception("Consumer error: {}".format(msg.error()))
            continue

        logger.info('Received message: %s', message)

更多日志

消费者组会话在 300005 毫秒后超时（处于稳定的加入状态），但组协调器没有成功响应（代理 5，最后一个错误是本地：队列中超时）：撤销分配并重新加入组

GroupCoordinator/5：超时 0 个正在进行中，0 个重试队列，1 个队列外，0 个部分发送的请求

GroupCoordinator/5: 飞行中的 OffsetCommitRequest 超时（60000 毫秒后，超时 #0） GroupCoordinator/5：飞行中的 OffsetCommitRequest 超时（60000 毫秒后，超时 #1） GroupCoordinator/5：飞行中的 OffsetCommitRequest 超时（60000 毫秒后，超时 #2 ) GroupCoordinator/5: 飞行中的 OffsetCommitRequest 超时（60000 毫秒后，超时 #3） GroupCoordinator/5：飞行中的 OffsetCommitRequest 超时（60000 毫秒后，超时 #4） GroupCoordinator/5：8301 飞行中超时，0 重试队列, 47924 出队, 1 部分发送的请求

4

0 回答 0