遇到这个问题Kafka消费者-请你让我知道，如果这是一个经纪人或消费者的问题？如果是消费者问题，是否有一个解决方法与下面给定的版本？
尝试调试在我的最后，以及-将更新与进展很快。
更新1-即使消费者重启也会增加复杂性；我无法解决这个问题，这让我觉得根本的问题在于经纪人。
使用@kafkalistener的spring kafka消费者
spring kafka版本-2.2.14.发布kafka客户端版本-kafka客户端-2.0.1
kafka集群在1.1.1上运行
更新2：我也看到了例外- Node 597397927 was unable to process the fetch request with (sessionId=1939114665, epoch=2): INVALID_FETCH_SESSION_EPOCH ```
Consumer exception - cause: {} - java.lang.IllegalStateException: Correlation id for response (400801) does not match request (400737), request header: RequestHeader(apiKey=OFFSET_COMMIT, apiVersion=3, clientId=consumer-7, correlationId=400737)
at org.apache.kafka.clients.NetworkClient.correlate(NetworkClient.java:853)
at org.apache.kafka.clients.NetworkClient.parseStructMaybeUpdateThrottleTimeMetrics(NetworkClient.java:638)
at org.apache.kafka.clients.NetworkClient.handleCompletedReceives(NetworkClient.java:757)
at org.apache.kafka.clients.NetworkClient.poll(NetworkClient.java:519)
at org.apache.kafka.clients.consumer.internals.ConsumerNetworkClient.poll(ConsumerNetworkClient.java:271)
at org.apache.kafka.clients.consumer.internals.ConsumerNetworkClient.poll(ConsumerNetworkClient.java:242)
at org.apache.kafka.clients.consumer.KafkaConsumer.pollForFetches(KafkaConsumer.java:1247)
at org.apache.kafka.clients.consumer.KafkaConsumer.poll(KafkaConsumer.java:1187)
at org.apache.kafka.clients.consumer.KafkaConsumer.poll(KafkaConsumer.java:1154)
at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.pollAndInvoke(KafkaMessageListenerContainer.java:742)
at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.run(KafkaMessageListenerContainer.java:699)
at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511)
at java.util.concurrent.FutureTask.run(FutureTask.java:266)
at java.lang.Thread.run(Thread.java:748)