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

KAFKA : find partition of message published?

我已经使用 KeyedMessage data = new KeyedMessage("topic",partition_key, msg);

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

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