search

robertluo / waterfall

The Unlicense
16 stars 1 forks source link

kafka 消费者出现停止消费现象 #20

Closed JackSho closed 1 year ago

JackSho commented 1 year ago

问题

相关日志

2023-03-02 14:08:26:068 +0800 [kafka-producer-network-thread | producer-2] INFO org.apache.kafka.clients.NetworkClient - [Producer clientId=producer-2] Node 2 disconnected.
2023-03-02 14:12:00:336 +0800 [kafka-producer-network-thread | producer-2] INFO org.apache.kafka.clients.NetworkClient - [Producer clientId=producer-2] Node 6 disconnected.
2023-03-02 14:18:34:952 +0800 [kafka-producer-network-thread | producer-1] INFO org.apache.kafka.clients.NetworkClient - [Producer clientId=producer-1] Node 7 disconnected.
2023-03-02 14:18:35:173 +0800 [kafka-coordinator-heartbeat-thread | app.event-app.0308-operation-drop-score] INFO org.apache.kafka.clients.consumer.internals.ConsumerCoordinator - [Consumer clientId=consumer-app.event-app.0308-operation-drop-score-1, groupId=app.event-app.0308-operation-drop-score] Group coordinator kafka-2.server:9092 (id: 2147483645 rack: null) is unavailable or invalid due to cause: session timed out without receiving a heartbeat response. isDisconnected: false. Rediscovery will be attempted.
2023-03-02 14:18:35:302 +0800 [kafka-coordinator-heartbeat-thread | app.event-app.0308-operation-drop-score] INFO org.apache.kafka.clients.consumer.internals.ConsumerCoordinator - [Consumer clientId=consumer-app.event-app.0308-operation-drop-score-1, groupId=app.event-app.0308-operation-drop-score] Requesting disconnect from last known coordinator kafka-2.server:9092 (id: 2147483645 rack: null)
2023-03-02 14:18:35:374 +0800 [kafka-coordinator-heartbeat-thread | app.event-app.0308-operation-drop-score] INFO org.apache.kafka.clients.NetworkClient - [Consumer clientId=consumer-app.event-app.0308-operation-drop-score-1, groupId=app.event-app.0308-operation-drop-score] Client requested disconnect from node 2147483645
2023-03-02 14:18:35:730 +0800 [manifold-execute-1] INFO org.apache.kafka.clients.consumer.internals.ConsumerCoordinator - [Consumer clientId=consumer-app.event-app.0308-operation-drop-score-1, groupId=app.event-app.0308-operation-drop-score] Discovered group coordinator kafka-2.server:9092 (id: 2147483645 rack: null)
2023-03-02 14:18:36:254 +0800 [kafka-coordinator-heartbeat-thread | app.event-app.0308-operation-drop-score] INFO org.apache.kafka.clients.consumer.internals.ConsumerCoordinator - [Consumer clientId=consumer-app.event-app.0308-operation-drop-score-1, groupId=app.event-app.0308-operation-drop-score] Attempt to heartbeat with Generation{generationId=11, memberId='consumer-app.event-app.0308-operation-drop-score-1-f6fa3481-c46b-42f7-ad56-31221eb0cabe', protocol='range'} and group instance id Optional.empty failed due to UNKNOWN_MEMBER_ID, resetting generation
2023-03-02 14:18:36:254 +0800 [kafka-coordinator-heartbeat-thread | app.event-app.0308-operation-drop-score] INFO org.apache.kafka.clients.consumer.internals.ConsumerCoordinator - [Consumer clientId=consumer-app.event-app.0308-operation-drop-score-1, groupId=app.event-app.0308-operation-drop-score] Resetting generation and member id due to: encountered UNKNOWN_MEMBER_ID from HEARTBEAT response
2023-03-02 14:18:36:254 +0800 [kafka-coordinator-heartbeat-thread | app.event-app.0308-operation-drop-score] INFO org.apache.kafka.clients.consumer.internals.ConsumerCoordinator - [Consumer clientId=consumer-app.event-app.0308-operation-drop-score-1, groupId=app.event-app.0308-operation-drop-score] Request joining group due to: encountered UNKNOWN_MEMBER_ID from HEARTBEAT response
2023-03-02 14:18:37:376 +0800 [manifold-execute-1] INFO org.apache.kafka.clients.consumer.internals.ConsumerCoordinator - [Consumer clientId=consumer-app.event-app.0308-operation-drop-score-1, groupId=app.event-app.0308-operation-drop-score] Failing OffsetCommit request since the consumer is not part of an active group
2023-03-02 14:19:22:641 +0800 [kafka-producer-network-thread | producer-2] INFO org.apache.kafka.clients.NetworkClient - [Producer clientId=producer-2] Node 0 disconnected.
2023-03-02 14:21:53:905 +0800 [kafka-producer-network-thread | producer-2] INFO org.apache.kafka.clients.NetworkClient - [Producer clientId=producer-2] Node 1 disconnected.
2023-03-02 14:27:11:170 +0800 [kafka-producer-network-thread | producer-2] INFO org.apache.kafka.clients.NetworkClient - [Producer clientId=producer-2] Node 6 disconnected.
2023-03-02 14:31:12:367 +0800 [kafka-producer-network-thread | producer-2] INFO org.apache.kafka.clients.NetworkClient - [Producer clientId=producer-2] Node 8 disconnected.