kafka-users mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Prabhu V <vpra...@gmail.com>
Subject Find partition offsets in a kerberized kafka cluster
Date Wed, 06 Jul 2016 18:02:38 GMT
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

Mime
  • Unnamed multipart/alternative (inline, None, 0 bytes)
View raw message