here’s an example of working code in java that use...

# announcements

[wei]

here’s an example of working code in java that uses it:

PartitionManager.KafkaMessageId id = (PartitionManager.KafkaMessageId) msgId;