apache-kafka - KAFKA：找到已发布消息的分区？

Question

我使用 KeyedMessage data = new KeyedMessage("topic",partition_key, msg); 发布了一条消息

如何重新检查消息是否到达了哪个分区？

Answer 1

当您使用 调用send()时KeyedMessage，将Future<RecordMetadata>返回 a。用于RecordMetadata.partition()获取分区。offset()返回偏移量。看这里：

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