apache-kafka - Is there a Telegraf plugin which takes in queries to read data from Influxdb and then post them on a kafka topic using the Kafka output plugin?

Question

Using Telegraf plugins, there is a way to read data from InfluxDb and publish it to a Kafka topic.

But is there a way to read the data on demand and place it on a Kafka topic? Like a query based demand.

I can do a query based read through REST API (curl GET).

There are HTTP Listener plugins but these are only for POST methods. None for GET method where I can query a subset of data from InfluxDb and place them on a Kafka topic. In this case, kafka would be the output plugin.

Answer 1

您可以使用 Kapacitor 的Kafka 事件处理程序来实现它。Kapacitor 可以在批处理模式或流模式下进行配置。在流模式的情况下，如果满足处理条件，Kapacitor 事件处理程序将立即处理记录并发送到 Kafaka 集群。请参阅此处了解更多详情。