[Logstash-input-kafka] 使用详解

Logstash-input-kafka是一个Logstash插件，用于从Kafka中消费消息并将其转发到Logstash管道中进行处理和分析。它支持从Kafka的不同分区和主题消费消息，并允许您使用各种不同的消费者组配置和选项。

要使用Logstash-input-kafka插件，您需要在Logstash配置文件中定义一个输入部分，如下所示：

input {
  kafka {
    bootstrap_servers => "kafka_host:port"
    topics => ["topic1", "topic2"]
    consumer_threads => 4
    group_id => "my-group"
  }
}

在上面的示例中，我们定义了一个Kafka输入插件，并指定了Kafka的引导服务器地址、要订阅的主题、消费者线程数量和消费者组ID。

一旦配置完成，Logstash-input-kafka插件将开始从Kafka中消费消息，并将其发送到Logstash管道中进行处理和分析。

注意：在使用Logstash-input-kafka插件时，确保已正确安装并配置了Kafka和Logstash，并且可以访问Kafka集群。