我正在使用kafka-kairosdb插件将 kafka 消息直接流式传输到 kairosDB。
我在文件夹中构建并成功添加了插件/lib，从日志中我看到该插件正在运行并连接到我的 kafka 主题。将消息发送到此主题后，插件不会继续进行，并且似乎保持打开状态for (MessageAndMetadata<byte[], byte[]> messageAndMetadata : m_stream)。
我没有更改配置中的任何内容，除了默认字符串解析器的主题名称以匹配我在 kafka 中的主题。