Logstash hangs with error sized_queue_timeout

Logstash 1.5.3
Kafka 0.8.
ES - 1.7.1

My pipeline looks like below:-

Multiple LF --- Logstash Collector --- Kafka---- Logstash Indexer --- ES
Cluster.

I am seeing the problem in logstash-collector.

Just to add in preparation for moving to beats I tried upgrading to
logstash 2.3.4. But that started giving some other issue:-

So at this point I am stuck with LSF.