spring-boot - KafkaHandler 从列表中消失在 org/springframework/kafka/listener/adapter/DelegatingInvocableHandler.java

Question

我的应用程序有 3 个KafkaHandler方法。在应用程序启动时，它会检测到这些方法，因为 List 处理程序具有所有 3 种方法。

但是，在一段时间后运行单元测试时，其中一个处理程序会超时消失。只有 2 个处理程序，其中一个是默认处理程序。用于处理有效负载类型的处理程序丢失

其他信息：

我正在调试模式下运行，但即使我跳过所有调试点也会出现此问题，我在调试模式下运行时看到以下异常嵌套异常是

org.apache.kafka.clients.consumer.CommitFailedException: Offset commit cannot be completed since the consumer is not part of an active group for auto partition assignment; it is likely that the consumer was kicked out of the group.
at org.springframework.kafka.listener.adapter.MessagingMessageListenerAdapter.invokeHandler(MessagingMessageListenerAdapter.java:350)
Version of spring-kafka is spring-kafka-2.5.10.RELEASE

标签： spring-bootspring-kafka