kafka消费者突然不消费了报 Offset commit failed on partition risk_gateway_etl-0 at offset 2579636: This is not the correct coordinator.

kafka消费者突然不消费了，有错误日志输出

kafka集群环境是3个节点，2副本，消费者模块最近时不时的无法消费消息，其中一个消费者错误日志如下：

2021-09-23 10:28:20.460 ERROR [Thread-10] [] o.a.kafka.clients.consumer.internals.ConsumerCoordinator - [Consumer clientId=consumer-1, groupId=gw_clm_consumer] Offset commit failed on partition risk_gateway_etl-0 at offset 2579636: This is not the correct coordinator.
2021-09-23 10:28:20.460 INFO [Thread-10] [] o.a.kafka.clients.consumer.internals.AbstractCoordinator - [Consumer clientId=consumer-1, groupId=gw_clm_consumer] Group coordinator 172.16.196.85:9092 (id: 2147483645 rack: null) is unavailable or invalid, will attempt rediscovery
2021-09-23 10:28:20.560 INFO [Thread-10] [] o.a.kafka.clients.consumer.internals.AbstractCoordinator - [Consumer clientId=consumer-1, groupId=gw_clm_consumer] Discovered group coordinator 172.16.196.84:9092 (id: 2147483647 rack: null)
2021-09-23 10:28:20.562 ERROR [Thread-10] [] o.a.kafka.clients.consumer.internals.ConsumerCoordinator - [Consumer clientId=consumer-1, groupId=gw_clm_consumer] Offset commit failed on partition risk_gateway_etl-0 at offset 2579636: The coordinator is not aware of this member.

另一个消费者错误日志如下：

而且另一个消费者在同一时间的错误日志是：

2021-09-23 10:28:19.247 ERROR [Thread-10] [] o.a.kafka.clients.consumer.internals.ConsumerCoordinator - [Consumer clientId=consumer-1, groupId=gw_clm_consumer] Offset commit failed on partition risk_gateway_etl-2 at offset 2577133: The request timed out.
2021-09-23 10:28:19.247 INFO [Thread-10] [] o.a.kafka.clients.consumer.internals.AbstractCoordinator - [Consumer clientId=consumer-1, groupId=gw_clm_consumer] Group coordinator 172.16.196.85:9092 (id: 2147483645 rack: null) is unavailable or invalid, will attempt rediscovery
2021-09-23 10:28:19.479 INFO [Thread-10] [] o.a.kafka.clients.consumer.internals.AbstractCoordinator - [Consumer clientId=consumer-1, groupId=gw_clm_consumer] Discovered group coordinator 172.16.196.85:9092 (id: 2147483645 rack: null)
2021-09-23 10:28:20.459 ERROR [Thread-10] [] o.a.kafka.clients.consumer.internals.ConsumerCoordinator - [Consumer clientId=consumer-1, groupId=gw_clm_consumer] Offset commit failed on partition risk_gateway_etl-2 at offset 2577133: This is not the correct coordinator.
2021-09-23 10:28:20.459 INFO [Thread-10] [] o.a.kafka.clients.consumer.internals.AbstractCoordinator - [Consumer clientId=consumer-1, groupId=gw_clm_consumer] Group coordinator 172.16.196.85:9092 (id: 2147483645 rack: null) is unavailable or invalid, will attempt rediscovery
2021-09-23 10:28:20.560 INFO [Thread-10] [] o.a.kafka.clients.consumer.internals.AbstractCoordinator - [Consumer clientId=consumer-1, groupId=gw_clm_consumer] Discovered group coordinator 172.16.196.84:9092 (id: 2147483647 rack: null)
2021-09-23 10:28:20.562 ERROR [Thread-10] [] o.a.kafka.clients.consumer.internals.ConsumerCoordinator - [Consumer clientId=consumer-1, groupId=gw_clm_consumer] Offset commit failed on partition risk_gateway_etl-2 at offset 2577133: The coordinator is not aware of this member.

另： 我在集群中其中一台broker里日志里看到如下信息：

[2021-09-23 10:28:10,998] INFO [ReplicaFetcherManager on broker 1] Removed fetcher for partitions elk-0(kafka.server.ReplicaFetcherManager)
[2021-09-23 10:28:10,998] INFO [ReplicaFetcherManager on broker 1] Added fetcher for partitions List([elk-0, initOffset 10040090963 to broker BrokerEndPoint(0,172.16.196.84,9092)] ) (kafka.server.ReplicaF
etcherManager)
[2021-09-23 10:28:10,998] INFO [ReplicaAlterLogDirsManager on broker 1] Added fetcher for partitions List() (kafka.server.ReplicaAlterLogDirsManager)
[2021-09-23 10:28:11,007] INFO [ReplicaFetcher replicaId=1, leaderId=2, fetcherId=0] Shutting down (kafka.server.ReplicaFetcherThread)
[2021-09-23 10:28:11,007] INFO [ReplicaFetcher replicaId=1, leaderId=2, fetcherId=0] Error sending fetch request (sessionId=1693859521, epoch=21103032) to node 2: java.nio.channels.ClosedSelectorException. (org.
apache.kafka.clients.FetchSessionHandler)
[2021-09-23 10:28:11,008] INFO [ReplicaFetcher replicaId=1, leaderId=2, fetcherId=0] Stopped (kafka.server.ReplicaFetcherThread)
[2021-09-23 10:28:11,008] INFO [ReplicaFetcher replicaId=1, leaderId=2, fetcherId=0] Shutdown completed(kafka.server.ReplicaFetcherThread)

以上问题查了些资料，但没有收获，希望能在这里找到答案。