KairosDB-Kafka 插件不接收消息

Question

我正在使用 kafka-kairosdb 插件直接将 kafka 消息传输到 kairosDB。

我在 /lib 文件夹中构建并成功添加了插件，从日志中我看到该插件是 运行 并且已连接到我的 kafka 主题。将消息发送到该主题后，插件没有继续进行，似乎停留在 for (MessageAndMetadata<byte[], byte[]> messageAndMetadata : m_stream).

除了默认字符串解析器的主题名称与我在 kafka 中的主题匹配外，我没有更改任何配置。

Answer 1

问题是插件kafka版本和我的实例版本不兼容。更改后，它运行良好。