elasticsearch - Logstash 从 Kafka 创建管道不起作用

Question

我正在尝试从 Kafka 主题获取数据以使用 Logstash 运行到 ELK 堆栈，但无法移动数据。

我将 logstash.conf 编辑为以下内容：

input {
        tcp {
            port => 5000
        }
        kafka {
            bootstrap_servers => "broker:29092"
            topics => ["PLACES_ROWKEY"]
        }
}

## Add your filters / logstash plugins configuration here

output {
        elasticsearch {
                hosts => ["elasticsearch:9200"]
                user => "elastic"
                password => "changeme"
                index => "from_logstash"
        }
}

如果重要的话，我会在 Docker 中运行这个设置（broker 是 Kafka 代理容器的主机名）。我重新启动 Logstash，但在 elasticsearch 中看不到任何新索引

标签： elasticsearchapache-kafkalogstash