Re: Kafka stops accepting messages for existing topics after a hostname change and restart

2013-10-04 Thread Neha Narkhede
Controlled shutdown is described here - https://cwiki.apache.org/confluence/display/KAFKA/Replication+tools#Replicationtools-1.ControlledShutdown On Fri, Oct 4, 2013 at 10:18 AM, Aniket Bhatnagar < aniket.bhatna...@gmail.com> wrote: > I did restart broker very quickly. I saw similar errors for a

Re: Kafka stops accepting messages for existing topics after a hostname change and restart

2013-10-04 Thread Aniket Bhatnagar
I did restart broker very quickly. I saw similar errors for about 5 mins and that's when I decided to shutdown all kafka brokers and start them one by one. That seems to have enabled writes in kafka instantly after brokers were back up. How do I do a controlled shutdown? The kafka shutdown script

Re: Kafka stops accepting messages for existing topics after a hostname change and restart

2013-10-04 Thread Neha Narkhede
When a broker starts up, it receives a LeaderAndIsrRequest from the controller broker telling the broker which partitions it should host and either lead or follow those partitions. If clients send requests to the broker before it has received this request, it throws this error you see. Did you rest

Kafka stops accepting messages for existing topics after a hostname change and restart

2013-10-04 Thread Aniket Bhatnagar
Because Kafka was detecting localhost.domain as hostname, I commented out the line "127.0.0.1 localhost.localdomain localhost" and added "127.0.0.1 ip-10-0-1-20.localdomain" in etc/hosts. When I restart Kafka (issues kill -15 pid), writes to existing topics are failing and I see several