Kevindyb opened a new issue, #908:
URL: https://github.com/apache/rocketmq-externals/issues/908
I have multiple configurations that need to be forwarded to ES, so I am
trying to add type in the input configuration. In the output configuration,
forwarding to different places based on different type values does not take
effect。
eg:
input {
rocketmq {
namesrv_addr => "xxxxx"
topic => "xx"
group => "xx"
sub_expression => "xx"
type => "test"
}
}
output {
if [type] == "test" {
elasticsearch {
hosts => "xxxx"
index => "xx-%{+YYYY}"
user => "xx"
password => "xx"
template_overwrite => true
template => "/../xx.json"
template_name => "xxx"
}
stdout {
codec => rubydebug {
}
}
}
}
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: dev-unsubscr...@rocketmq.apache.org.apache.org
For queries about this service, please contact Infrastructure at:
us...@infra.apache.org
