Find partition offsets in a kerberized kafka cluster

[Prabhu V]

Hi,

Does the kafka.tools.GetOffsetShell utility work with a kerberized kafka
cluster ?

I doubt that it uses the old consumer which does not work with kerberos and
hence cannot be used with kerberos.

Is there a utlity that has this functionality in a kerberized cluster ?

I currently do this by the following code on the new consumer. Let me know
if there is a better way.

partsTopic is a array of TopicPartition

consumer.assign(Arrays.asList(partsTopic));
consumer.seekToEnd(partsTopic);

for (TopicPartition partTopic : partsTopic) {
            log.info(String.format("%s, offset - %s", partTopic.toString(),
                    consumer.position(partTopic)));
}


Thanks,
Prabhu