Фильтрация сообщений в Telegraf с помощью плагина ввода kafka - PullRequest
Новая
       51

Фильтрация сообщений в Telegraf с помощью плагина ввода kafka

0 голосов
/ 17 июня 2020

Я использую следующую конфигурацию: 

# Read metrics from Kafka topic(s)
[[inputs.kafka_consumer]]
  topics = ["telegraf"]
  brokers = ["localhost:9092"]
  consumer_group = "telegraf_metrics_consumers"
  offset = "oldest"

  ## Data format to consume.
  data_format = "influx"

  ## Maximum length of a message to consume, in bytes (default 0/unlimited);
  ## larger messages are dropped
  max_message_len = 65536

Есть ли способ фильтровать сообщения по измерениям и обрабатывать (в данном конкретном случае, запись в InfluxDB) только те, которые настроены? В топи c много событий, которые меня не интересуют.

В другом топи c, где я получаю сообщения в формате JSON, фильтрую их без проблем через поле tag_keys.

Заранее спасибо

...