我的JavaSpring应用程序正在成功地使用来自kafka0.9.0.0的消息。但是我转到了kafka0.10.2.0,这是kerberos身份验证。所以在这个新的kafka0.10上,当我启动我的消费应用程序时,它建立了kerberos身份验证,并且使用良好。但过了一段时间(不确定的时间有时是6小时,20小时,80小时),它将停止消费信息。一旦我重新启动应用程序,它将处理所有未使用的消息,使用一段时间,然后再次停止。我不理解这种奇怪的消费/Kafka/kerberos场景。有人能帮助我如何使我的应用程序持续消费吗?提前谢谢。
暂无答案!
目前还没有任何答案,快来回答吧!