我使用kafka kairosdb插件将kafka消息直接流式传输到kairosdb中。
我构建并成功添加了插件 /lib 文件夹和日志，我看到插件正在运行，并连接到我的Kafka主题。在发送消息到这个主题后，它不是由插件继续进行的，它似乎是保持不变的 for (MessageAndMetadata<byte[], byte[]> messageAndMetadata : m_stream) .
我没有更改任何配置，除了默认stringparser的主题名，以匹配我在kafka中的主题。