使用telegraf插件，可以从xdb读取数据并将其发布到kafka主题。
但是有没有一种方法可以按需读取数据并将其放在Kafka的主题上呢？就像一个基于查询的需求。
我可以通过restapi（curl-get）进行基于查询的读取。
有http侦听器插件，但这些插件仅用于post方法。在get方法中，我可以从xdb查询数据子集，并将它们放在kafka主题上。在本例中，kafka将是输出插件。
使用telegraf插件，可以从xdb读取数据并将其发布到kafka主题。
但是有没有一种方法可以按需读取数据并将其放在Kafka的主题上呢？就像一个基于查询的需求。
我可以通过restapi（curl-get）进行基于查询的读取。
有http侦听器插件，但这些插件仅用于post方法。在get方法中，我可以从xdb查询数据子集，并将它们放在kafka主题上。在本例中，kafka将是输出插件。
1条答案
按热度按时间rur96b6h1#
您可以使用kapacitor的kafka事件处理程序来实现它。kapacitor可以在批处理模式或流模式下配置。在流模式下，如果满足处理条件，kapacitor事件处理程序将立即处理记录并发送到kafaka集群。详情请参阅此处。