Help needed with Batch Expired exception

2017-06-25 Thread Sreeram
Hi, I am trying to send messages (synchronous) to a kafka cluster (lets call it A). I get 'Batch Expired Exception' very frequently. Also the average time taken per send is very high around 5 seconds. However for the same code when I send messages to a different kafka cluster B (with same netwo

Help needed with Batch Expired exception

2017-06-24 Thread Sreeram
Hi, I am trying to send messages (synchronous) to a kafka cluster (lets call it A). I get 'Batch Expired Exception' very frequently. Also the average time taken per send is very high around 5 seconds. However for the same code when I send messages to a different kafka cluster B (with same netwo