logstash从kafka创建管道不起作用

5jdjgkvh  于 2021-06-05  发布在  Kafka
关注(0)|答案(0)|浏览(266)

我试图从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 broker容器的主机名)。我重新启动了logstash,但在elasticsearch中看不到任何新的索引

暂无答案!

目前还没有任何答案,快来回答吧!

相关问题