Hello, I want to count how many messages available in each topic in my kafka cluster. I understand that just looking at the latest offset available is not correct, because older messages may have been already purged due to retention policy. So what is the correct way of counting that?
Thanks, Jazz.
