Logstash kafka topic als Teil von elasticsearch indexname

Question

Ich möchte kafka topic als Teil von es-indexname verwenden. Hier ist mein Beispiel, aber das funktioniert nicht:

Kann jemand das Problem in dieser logstash.conf finden?

Answer 1

hallo dies funktioniert config:

input { 
    kafka {  
    ... 
    decorate_events => true 
    } 
} 

filter {  
    mutate { 
    add_field => {"[@metadata][index]" => "%{[kafka][topic]}"} 
    } 
} 

output { 
    elasticsearch { 
    index => "kafka-%{[@metadata][index]}-%{+YYYY.MM.dd}" 
    ... 
    } 
}