要配置 Filebeat 采集 Kafka 的不同 Topic,需要在 Filebeat 的输入配置中为每个 Topic 指定一个单独的输入。以下是示例配置:

filebeat.inputs:
- type: kafka
  hosts:
    - kafka:9092
  topics:
    - 'my_topic_1'
  group_id: 'my_consumer_group_1'
  ...
- type: kafka
  hosts:
    - kafka:9092
  topics:
    - 'my_topic_2'
  group_id: 'my_consumer_group_2'
  ...

在上面的示例中,我们创建了两个 kafka 输入,每个输入都指定了一个不同的 Topic 和 group_id。您可以根据需要添加更多的输入并为每个 Topic 指定不同的输入。

Filebeat 配置采集 Kafka 多个 Topic 数据

原文地址: https://www.cveoy.top/t/topic/oPIZ 著作权归作者所有。请勿转载和采集!

免费AI点我,无需注册和登录