LogStash特定のパーティションへのKafka出力

Question

kafkaトピックとそのカフカトピック内の特定のパーティションに出力するようにlogstashを設定するにはどうすればよいですか？

output { 
    kafka { 
    codec => plain { format => "%{message}" } 
    topic_id => "data_raw" 
    } 
} 

Answer 1

プラグインは特定のパーティションを定義するのにmessage_keyオプションを使用します。

hereの実装を確認してください。