Hello, I tried to find this information, but may be I searched for the wrong stuff.
I am trying to identify what's the last message written on a TopicPartition. My constraints are: 1) No Knowledge of the last offset - so I cannot use seek(TopicPartition, long) 2) I have to retrieve the last-written data in that TopicPartition to determine some checkpoint information. Currently, if I do a subscribe() and poll() I get all records for all TopicPartitions. But i would like to find out only the last item My issue is that I need to do this only once every time my producer starts up. I need to retrieve only the last message written on a TopicPartition without going through all records. AFAIK, there is no mechanism in Kafka that does exactly that. Could anyone please help me understand? Regards,
