Neha,
In the log I found: kafka.consumer.TopicCount$ - error parsing consumer
json string { "DS.Input.All.Gyaolan": 1 } java.lang.NullPointerException
So the exception is caused by the unthread-safe bug in TopicCount. More
details see https://issues.apache.org/jira/browse/KAFKA-379
The version of Kafka I used is 0.7.1, the bug is not fixed yet and I don't
know if it will be fixed in this version. So, I would like to know what
should I do in my case?
Many Thanks.
Adam.
On Fri, Nov 23, 2012 at 2:42 AM, Neha Narkhede <neha.narkh...@gmail.com>wrote:
> Can you please send around the entire consumer log that leads to
> ConsumerRebalanceFailedException ? That exception means the consumer
> will not be able to startup. There can be several problems that can
> lead to this exception, most commonly includes inability to connect to
> zookeeper.
>
> Thanks,
> Neha
>
> On Thu, Nov 22, 2012 at 9:04 AM, sun liwei <slivey...@gmail.com> wrote:
> > Hi, all
> >
> > The code is like this:
> >
> > ConsumerConnector consumer = ...;
> > Map<String, Integer> topicCountMap = ...;
> > Map<String, List<KafkaStream<Message>>> consumerMap = null;
> > KafkaStream<Message> stream = null;
> >
> > try{
> > topicCountMap.put(topic, new Integer(1));
> > consumerMap = consumer.createMessageStreams(topicCountMap);
> > stream = consumerMap.get(topic).get(0);
> > }catch(Exception e){
> >
> > }finally{
> > *// shall I shutdown the consumer here? or should I call
> *
> > //consumer.shutdown();
> > //consumer = null;
> > }
> >
> > Actually the exception is:
> *kafka.common.ConsumerRebalanceFailedException:
> > ***-1353254404267-5541f750 can't rebalance after 4 retries*
> >
> > Thank you very much!
> >
> > Adam
>
