here’s the code for it: ```static class KafkaMessa...

# announcements

[wei]

here’s the code for it:

static class KafkaMessageId {
        public Partition partition;
        public long offset;

        public KafkaMessageId(Partition partition, long offset) {
            this.partition = partition;
            this.offset = offset;
        }
    }