logstash从es读数据输出到kafka

请教各位大佬，如何配置这种输入输出方式？ 附上我的不可行配置：
input {
elasticsearch {
hosts => ["XXX"]
index => "xxx*"
query =>'{"query":{"match_all":{}}}'
docinfo => true
}
}

filter {

}
output {

stdout {
codec => rubydebug
}

kafka {
id => "sh_kafka"
bootstrap_servers => "XXXX"
topic_id => "TEST"
linger_ms => 1
codec => "json"
}
}