我试图从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中看不到任何新的索引
暂无答案!
目前还没有任何答案,快来回答吧!