Re: kafka.common.NoBrokersForPartitionException: Partition = null

2014-01-07 Thread Jun Rao
> > > > > > > > There are 3 zookepers and one broker, Kafka 0.7.2. > > > > > I got some temporary problems in zk cluster enviornment, but, any > zk > > > > > processes didn't go down. > > > > > > > > > > A br

Re: kafka.common.NoBrokersForPartitionException: Partition = null

2014-01-07 Thread Cheolwoo Choi
;t go down. > > > > > > > > A broker got zk session timeout message, then got zk disconnected and > > > > expired message. > > > > After 10 secs, the broker reconnected to the zk with new zk session > id, > > > > then it regitsterd all topics successfully. > > > > > > > > But, kafka producers continuously throw > > > > "kafka.common.NoBrokersForPartitionException: Partition = null". > > > > The broker had got back in stable. However, producers didn't stop to > > > throw > > > > the exceptions. > > > > > > > > How can I prevent that problem ? > > > > > > > > Thanks, > > > > > > > > > >

Re: kafka.common.NoBrokersForPartitionException: Partition = null

2014-01-07 Thread Jun Rao
fter 10 secs, the broker reconnected to the zk with new zk session id, > > > then it regitsterd all topics successfully. > > > > > > But, kafka producers continuously throw > > > "kafka.common.NoBrokersForPartitionException: Partition = null". > > > The broker had got back in stable. However, producers didn't stop to > > throw > > > the exceptions. > > > > > > How can I prevent that problem ? > > > > > > Thanks, > > > > > >

Re: kafka.common.NoBrokersForPartitionException: Partition = null

2014-01-07 Thread Cheolwoo Choi
econnected to the zk with new zk session id, > > then it regitsterd all topics successfully. > > > > But, kafka producers continuously throw > > "kafka.common.NoBrokersForPartitionException: Partition = null". > > The broker had got back in stable. However, producers didn't stop to > throw > > the exceptions. > > > > How can I prevent that problem ? > > > > Thanks, > > >

Re: kafka.common.NoBrokersForPartitionException: Partition = null

2014-01-07 Thread Jun Rao
> > A broker got zk session timeout message, then got zk disconnected and > expired message. > After 10 secs, the broker reconnected to the zk with new zk session id, > then it regitsterd all topics successfully. > > But, kafka producers continuously throw > "kafka.common

Re: kafka.common.NoBrokersForPartitionException: Partition = null

2014-01-06 Thread Joe Stein
sconnected and > expired message. > After 10 secs, the broker reconnected to the zk with new zk session id, > then it regitsterd all topics successfully. > > But, kafka producers continuously throw > "kafka.common.NoBrokersForPartitionException: Partition = null". > The b

kafka.common.NoBrokersForPartitionException: Partition = null

2014-01-06 Thread Cheolwoo Choi
with new zk session id, then it regitsterd all topics successfully. But, kafka producers continuously throw "kafka.common.NoBrokersForPartitionException: Partition = null". The broker had got back in stable. However, producers didn't stop to throw the exceptions. How can I