错误处理程序抛出异常：Kafka 消费者 CommitFailedException
Error handler threw an exception: Kafka consumer CommitFailedException
无法完成偏移量提交，因为消费者不属于自动分区分配的活动组；很可能是消费者被踢出了群
Kafka 正在工作，如果它正在使用消息，并且使用的消息将通过 restTemplate 发送到服务，但不知何故 restTemplate 由于连接而失败，但我收到 Kafka 的错误消息。
restTemplate失败时Kafka消费的问题是什么？
[org.springframework.kafka.KafkaListenerEndpointContainer#3-0-C-1] 错误 o.s.k.l.KafkaMessageListenerContainer$ListenerConsumer - 错误处理程序抛出异常
org.apache.kafka.clients.consumer.CommitFailedException：无法完成偏移量提交，因为消费者不属于自动分区分配的活动组；消费者很可能被踢出组。
在 org.apache.kafka.clients.consumer.internals.ConsumerCoordinator.sendOffsetCommitRequest(ConsumerCoordinator.java:1116)
在 org.apache.kafka.clients.consumer.internals.ConsumerCoordinator.commitOffsetsSync(ConsumerCoordinator.java:983)
在 org.apache.kafka.clients.consumer.KafkaConsumer.commitSync(KafkaConsumer.java:1510)
在 org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.doCommitSync(KafkaMessageListenerContainer.java:2209)
在 org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.commitSync(KafkaMessageListenerContainer.java:2204)
在 org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.commitIfNecessary(KafkaMessageListenerContainer.java:2190)
在 org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.processCommits(KafkaMessageListenerContainer.java:2004)
在 org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.invokeErrorHandler(KafkaMessageListenerContainer.java:1906)
在 org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.doInvokeRecordListener(KafkaMessageListenerContainer.java:1812)
在 org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.doInvokeWithRecords(KafkaMessageListenerContainer.java:1739)
在 org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.invokeRecordListener(KafkaMessageListenerContainer.java:1636)
在 org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.invokeListener(KafkaMessageListenerContainer.java:1366)
在 org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.pollAndInvoke(KafkaMessageListenerContainer.java:1082)
在 org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.run(KafkaMessageListenerContainer.java:990)
在 java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511)
在 java.util.concurrent.FutureTask.run(FutureTask.java:266)
一般表示消费者处理poll()返回的记录时间过长。
您需要减少 max.poll.records and/or 增加 max.poll.interval.ms 以便在间隔到期之前处理轮询返回的所有记录。
无法完成偏移量提交，因为消费者不属于自动分区分配的活动组；很可能是消费者被踢出了群
Kafka 正在工作，如果它正在使用消息，并且使用的消息将通过 restTemplate 发送到服务，但不知何故 restTemplate 由于连接而失败，但我收到 Kafka 的错误消息。 restTemplate失败时Kafka消费的问题是什么？
[org.springframework.kafka.KafkaListenerEndpointContainer#3-0-C-1] 错误 o.s.k.l.KafkaMessageListenerContainer$ListenerConsumer - 错误处理程序抛出异常 org.apache.kafka.clients.consumer.CommitFailedException：无法完成偏移量提交，因为消费者不属于自动分区分配的活动组；消费者很可能被踢出组。 在 org.apache.kafka.clients.consumer.internals.ConsumerCoordinator.sendOffsetCommitRequest(ConsumerCoordinator.java:1116) 在 org.apache.kafka.clients.consumer.internals.ConsumerCoordinator.commitOffsetsSync(ConsumerCoordinator.java:983) 在 org.apache.kafka.clients.consumer.KafkaConsumer.commitSync(KafkaConsumer.java:1510) 在 org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.doCommitSync(KafkaMessageListenerContainer.java:2209) 在 org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.commitSync(KafkaMessageListenerContainer.java:2204) 在 org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.commitIfNecessary(KafkaMessageListenerContainer.java:2190) 在 org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.processCommits(KafkaMessageListenerContainer.java:2004) 在 org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.invokeErrorHandler(KafkaMessageListenerContainer.java:1906) 在 org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.doInvokeRecordListener(KafkaMessageListenerContainer.java:1812) 在 org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.doInvokeWithRecords(KafkaMessageListenerContainer.java:1739) 在 org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.invokeRecordListener(KafkaMessageListenerContainer.java:1636) 在 org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.invokeListener(KafkaMessageListenerContainer.java:1366) 在 org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.pollAndInvoke(KafkaMessageListenerContainer.java:1082) 在 org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.run(KafkaMessageListenerContainer.java:990) 在 java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511) 在 java.util.concurrent.FutureTask.run(FutureTask.java:266)
一般表示消费者处理poll()返回的记录时间过长。
您需要减少 max.poll.records and/or 增加 max.poll.interval.ms 以便在间隔到期之前处理轮询返回的所有记录。