更新camus中的kafka依赖关系导致etlrecordreader无法读取消息

eivnm1vs  于 2021-06-06  发布在  Kafka
关注(0)|答案(0)|浏览(181)

在我的项目加缪是使用了很长时间,它是永远不会得到更新。camus项目使用kafka版本0.8.2.2。我想找到一个解决方法来使用Kafka1.0.0。
所以我克隆了目录并更新了依赖关系。当我这样做的时候,这里的消息需要额外的参数。
正如上面github链接中给出的,代码可以编译,但是由于这里的条件,消息不会从kafka读取。
有没有可能更新kafka依赖项以及相应的数据构造函数 kafka.message.Message 让它工作。

暂无答案!

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

相关问题