Especially when writing tests with testcontainers (fresh broker for each restart of container), it is useful to be able to ask a topic for its latest offset, and then decide whether to set up additional test data or not. You could sort of do it today with KafkaTestUtils but you'd have to block and wait for a message, and if there were no messages it would timeout before you got the answer.