Hi, I know kafka.tools.ConsumerOffsetChecker can find out the latest offset for a topic from log files internally. Is there any public API that users can use for that?
This would be useful for the failover scenario. When one cluster is down, the publisher will publish to the backup cluster. But the backup cluster always lags behind. If it is possible for publisher to find out the latest offset from the backup, it can always publish from that offset assuming publisher has a large enough buffer. This guarantees no message loss. Thanks. Libo
