Kafka ConcurrentMessageListenerContainer 突然停止消费

Question

我正在使用 Spring kafka 使用 ConcurrentMessageListenerContainer 来消费消息，在生产中我看到它突然停止消费消息，没有任何错误，有时甚至一个带有 VM 的消费者停止消费，而其他消费者仍在消费（我有 15 partitions和3个JVM，每个都有5个并发）。

当我重新启动 JVM 时，它开始消耗！！！

无论如何我可以定期检查消费者是否已经死亡或其他什么，我可以在不重新启动 JVM 的情况下重新启动它！

Answer 1

很可能，消费者线程“卡”在您的代码中的某个地方。我建议您在发生这种情况时进行线程转储，以查看线程在做什么。