我只是使用kafka运行一个简单的任务,在同一个主题中连接两个入站适配器。它有以下例外:
java.lang.illegalstateexception:迭代器在kafka.utils.iteratortemplate.hasnext(iteratortemplate)处处于失败状态。scala:54)
它的工作与1入境罚款。我搜索了一下,发现人们到目前为止都遇到过这个问题。但他们的解决方案似乎不适用于我的情况(下面建议使用最新版本,但我使用的是最新版本)
从kafka失败的迭代器消费处于失败状态
任何帮助都将不胜感激!谢谢你们!
暂无答案!
目前还没有任何答案,快来回答吧!