Kafka ConcurrentMessageListenerContainer 突然停止消费

Question

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

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

有没有我可以定期检查消费者是否死了之类的东西并且我可以在不重新启动 JVM 的情况下重新启动它！！

Answer 1

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