@Sunil On Fri, Mar 20, 2015 at 3:36 PM, sunil kalva <sambarc...@gmail.com> wrote: > I think KafkaProducer.send method blocks until it fetches partition > metadata for configured time using "metadata.fetch.timeout.ms", once time > out it throws TimeoutException. You might be experiencing TimeoutException ?
My co-worker pointed out that over here: https://github.com/apache/kafka/blob/0.8.2/clients/src/main/java/org/apache/kafka/clients/producer/KafkaProducer.java#L368 waitOnMetadata just returns. The else branch of the code is not executed when Kafka is unreachable. Trying to investigate what else must be causing the wait.
