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

【问题标题】：KAFKA : find partition of message published?KAFKA：找到已发布消息的分区？
【发布时间】：2016-02-25 07:52:05
【问题描述】：

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

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

【问题讨论】：

【解决方案1】：

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

【讨论】：

如何访问 Future ？
查看 javadoc 了解如何使用 Future：docs.oracle.com/javase/7/docs/api/java/util/concurrent/…
我正在尝试 Future fet = producer.send(data);