我正在使用Spring kafka通过ConcurrentMessageListenerContainer消费消息，在生产中我看到它突然停止消费消息，而没有任何错误，有时甚至一个拥有VM的使用者也停止消费，而其他使用者仍在使用（我有15个分区和3个分区JVM，每个具有5的并发性。
当我重新启动JVM时，它开始消耗!!!
无论如何，我可以定期检查使用者是否死亡或什么原因，而无需重新启动JVM就可以重新启动它！
使用者线程最有可能“卡在”您的代码中的某个位置。我建议您在发生这种情况时进行线程转储，以查看线程在做什么。
本文收集自互联网，转载请注明来源。
如有侵权，请联系[email protected] 删除。
我来说两句