kafka:got invalid 运行多个入站适配器时的迭代器状态

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

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

暂无答案!

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

相关问题