Hi all,
I'm running Kafka 0.7 and I'm having problems running the ConsumerOffsetChecker.
I have messages loaded in a topic called eventdata and I can consume the
messages fine but when I try to run ConsumerOffsetChecker I get the following
error:
[2013-12-13 12:24:48,034] INFO zookeeper state changed (SyncConnected)
(org.I0Itec.zkclient.ZkClient)
xon,eventdata,1-0 (Group,Topic,BrokerId-PartitionId)
Owner = null
Consumer offset = 27199655
= 27,199,655 (0.03G)
[2013-12-13 12:24:48,223] ERROR Could not parse broker info
prdslsldstkfk01-1384813902983:prdslsldstkfk01:909
2 (kafka.tools.ConsumerOffsetChecker$)
xon,eventdata,1-1 (Group,Topic,BrokerId-PartitionId)
Owner = null
Consumer offset = 26759625
= 26,759,625 (0.02G)
xon,eventdata,1-2 (Group,Topic,BrokerId-PartitionId)
I looked in zookeeper and I see that I have
prdslsldstkfk01-1384813902983:prdslsldstkfk01:909
2 for my /brokers/ids/1 entry in Zookeeper and it seems that Kafka is not able
to parse this broker from this string. Can anyone tell me what is wrong with
it? Does it have to be in some other format or is there some information
missing?