apache-kafka - 更新 camus 中的 kafka 依赖项导致 EtlRecordReader 未读取消息

Question

在我的项目中，camus 使用了很长时间，并且永远不会更新。camus项目使用kafka 0.8.2.2版本。我想找到一种解决方法来使用 kafka 1.0.0。

所以我克隆了目录并更新了依赖项。当我这样做时，此处的消息需要此处的附加参数。

如上面的 github 链接中给出的，代码可以编译，但是由于这里的条件，没有从 kafka 读取消息。

是否可以更新 kafka 依赖项以及适当的数据构造函数kafka.message.Message并使其工作。