是时候用 ES 拯救发际线啦

logstash配置文件中output 怎么获得input下kafka的id??

Logstash | 作者 iuiufa | 发布于2017年04月20日 | 阅读数:4959

我的配置是这样的,这是input内容
input {
    kafka {
        id => "kafka_1"
        ...
                ...
        bootstrap_servers => "localhost:9092"        
    }
}
output内容是这样的:
output {
    elasticsearch {
        hosts => "172.19.100.210:9200"    
        ...
        index => "bwae-%{id}-%{+YYYY-MM-dd}"    
    }
}

output的%{id}无法取到input下的kafka里的id,请问各位大神们这个问题该怎么解决
已邀请:

要回复问题请先登录注册