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

Error from producer sync API "Broker: Request timed out"

2016-02-22 Thread ANKUR JOHRI
Hi, There is a producer which uses librdkafka to send messages over a Kafka infrastructure. There is an error which occurred from sync API call. It gives error message "Broker: Request timed out". To give some context of the scenario, there are two brokers - broker 2 on local host being the pr