apache-kafka - KAFKA : 発行されたメッセージのパーティションを見つけますか?

Question

KeyedMessage data = new KeyedMessage("topic",partition_key, msg); を使用してメッセージを公開しました。

メッセージがどのパーティションに送信されたかを再確認する方法は?

Answer 1

で呼び出すsend()とKeyedMessage、 aFuture<RecordMetadata>が返されます。RecordMetadata.partition()パーティションを取得するために使用します。offset()オフセットを返します。ここを参照してください：

http://kafka.apache.org/082/javadoc/org/apache/kafka/clients/producer/RecordMetadata.html