kafka消费者在使用kerberos身份验证一段时间后停止消费

nue99wik  于 2021-06-08  发布在  Kafka
关注(0)|答案(0)|浏览(270)

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

暂无答案!

目前还没有任何答案,快来回答吧!

相关问题