我保存了一个非常基本的conf文件,它从文件夹中读取日志并将其推送到kafka,如下所示:
input {
file
{
add_field => { "app_id" => "12345"}
path => "/tmp/logs/*.log"
start_position => "beginning"
}
}
output {
if [app_id] == "12345" {
kafka {
topic_id => "mytopic"
bootstrap_servers => "kafka_topic_id:9043"
ssl => false
}
}
}
我的日志显示“管道主启动”。但是我在Kibana没有看到任何东西。这意味着要么流没有被推送到kafka,要么从kafka到elastic的搜索数据没有被推送到kafka。我错过了什么吗?
暂无答案!
目前还没有任何答案,快来回答吧!