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.
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.
Comments
Post a Comment