如何解决带有 kafka 的 InfluxDB 2.0
我正在使用 Influxdb 2.0 版,并希望将 kafka 消费者遗留插件与其连接。我想知道我应该如何配置kafka consumer legacy的这个配置文件以及将它放在服务器/本地机器上的哪个路径?
InfluxDB Sink Connector for Confluent Platform 不支持此版本从以下链接得知:
Does Confluent's InfluxDB Sink Connector work with InfluxDB 2.0?
kafka消费者遗留的配置文件如下:
# Read metrics from Kafka topic(s)
[[inputs.kafka_consumer]]
## topic(s) to consume
topics = ["telegraf"]
## an array of Zookeeper connection strings
zookeeper_peers = ["localhost:2181"]
## Zookeeper Chroot
zookeeper_chroot = ""
## the name of the consumer group
consumer_group = "telegraf_metrics_consumers"
## Offset (must be either "oldest" or "newest")
offset = "oldest"
## Data format to consume.
## Each data format has its own unique set of configuration options,read
## more about them here:
## https://github.com/influxdata/telegraf/blob/master/docs/DATA_FORMATS_INPUT.md
data_format = "influx"
## Maximum length of a message to consume,in bytes (default 0/unlimited);
## larger messages are dropped
max_message_len = 65536
解决方法
除非您使用的是 Kafka new consumer plugin,但旧版将在配置文件中进行类似配置。
话虽如此,Telegraf 是一个独立的进程,与运行 Influx 无关,可以通过
telegraf --config your_config.conf
如果你想写入那个版本,你可以使用相应的 Influx 2.0 output plugin