logstash连接kafka

要在Logstash中连接Kafka，你需要使用Kafka输入插件。该插件允许你从Kafka主题中读取消息并将其发送到Logstash进行处理。以下是一个简单的Logstash配置文件示例，用于连接到Kafka：

input {
  kafka {
    bootstrap_servers => "kafka_host:port"
    topics => ["your_topic"]
    group_id => "your_group_id"
    consumer_threads => 1
  }
}

output {
  stdout {
    codec => rubydebug
  }
  # 其他输出插件配置...
}

在这个配置中，你需要将"bootstrap_servers"替换为你的Kafka服务器主机名和端口号。"topics"用于指定要从中读取消息的主题名称。"group_id"用于标识消费者组。你还可以根据需要配置其他参数。

当Logstash连接到Kafka后，它将从指定的主题中读取消息，并根据配置的输出插件将其发送到不同的目标（例如，标准输出、Elasticsearch等）。