Kafka error code: 7 (RequestTimedOut)

2016-02-24 Thread ANKUR JOHRI
I have a Kafka infrastructure in which there is 1 topic (T) with 1 partition and replication factor 2. There are 2 brokers - B1 and B2 in the associated zookeeper. The two brokers are on two different hosts - host 1 and host 2. The leader is on host1, which is defined to be local in context of a p

Kafka error code: 7 (RequestTimedOut)

2016-02-24 Thread Ankur Johri
Hi, I have a Kafka infrastructure in which there is 1 topic (T) with 1 partition and replication factor 2. There are 2 brokers - B1 and B2 in the associated zookeeper. The two brokers are on two different hosts - host 1 and host 2. The leader is on host1, which is defined to be local in context