Home | About | Sematext search-lucene.com search-hadoop.com
 Search Hadoop and all its subprojects:

Switch to Threaded View
Kafka, mail # user - Error messages in logs


Copy link to this message
-
Re: Error messages in logs
Joel Koshy 2013-08-12, 17:20
The consumer uses a sync.producer to look up topic metadata for topics
that it consumes. For some reason, it is unable to establish a
connection to the brokers. Are the brokers all up with clean logs?

On Mon, Aug 12, 2013 at 8:39 AM, Eric Sites <[EMAIL PROTECTED]> wrote:
> I am getting some new messages in my 0.8 Java producer app.
>
> I am running 6 Kafka brokers.
>
> The app producing these logs messages is not doing anything, i.e. Not producing messages.
>
> Anywhere form every 5 minutes to 10 seconds sometimes.
>
> [2013-08-12 14:45:20,714] ERROR Producer connection to kafka002:9092 unsuccessful (kafka.producer.SyncProducer)
> java.nio.channels.ClosedByInterruptException
> at java.nio.channels.spi.AbstractInterruptibleChannel.end(AbstractInterruptibleChannel.java:184)
> at sun.nio.ch.SocketChannelImpl.connect(SocketChannelImpl.java:543)
> at kafka.network.BlockingChannel.connect(BlockingChannel.scala:57)
> at kafka.producer.SyncProducer.connect(SyncProducer.scala:146)
> at kafka.producer.SyncProducer.getOrMakeConnection(SyncProducer.scala:161)
> at kafka.producer.SyncProducer.kafka$producer$SyncProducer$$doSend(SyncProducer.scala:68)
> at kafka.producer.SyncProducer.send(SyncProducer.scala:112)
> at kafka.client.ClientUtils$.fetchTopicMetadata(ClientUtils.scala:53)
> at kafka.client.ClientUtils$.fetchTopicMetadata(ClientUtils.scala:88)
> at kafka.consumer.ConsumerFetcherManager$LeaderFinderThread.doWork(ConsumerFetcherManager.scala:64)
> at kafka.utils.ShutdownableThread.run(ShutdownableThread.scala:51)
> [2013-08-12 14:45:20,714] ERROR Producer connection to kafka006:9092 unsuccessful (kafka.producer.SyncProducer)
> java.nio.channels.ClosedByInterruptException
> at java.nio.channels.spi.AbstractInterruptibleChannel.end(AbstractInterruptibleChannel.java:184)
> at sun.nio.ch.SocketChannelImpl.connect(SocketChannelImpl.java:543)
> at kafka.network.BlockingChannel.connect(BlockingChannel.scala:57)
> at kafka.producer.SyncProducer.connect(SyncProducer.scala:146)
> at kafka.producer.SyncProducer.getOrMakeConnection(SyncProducer.scala:161)
> at kafka.producer.SyncProducer.kafka$producer$SyncProducer$$doSend(SyncProducer.scala:68)
> at kafka.producer.SyncProducer.send(SyncProducer.scala:112)
> at kafka.client.ClientUtils$.fetchTopicMetadata(ClientUtils.scala:53)
> at kafka.client.ClientUtils$.fetchTopicMetadata(ClientUtils.scala:88)
> at kafka.consumer.ConsumerFetcherManager$LeaderFinderThread.doWork(ConsumerFetcherManager.scala:64)
> at kafka.utils.ShutdownableThread.run(ShutdownableThread.scala:51)
> [2013-08-12 14:45:20,715] ERROR Producer connection to kafka001:9092 unsuccessful (kafka.producer.SyncProducer)
> java.nio.channels.ClosedByInterruptException
> at java.nio.channels.spi.AbstractInterruptibleChannel.end(AbstractInterruptibleChannel.java:184)
> at sun.nio.ch.SocketChannelImpl.connect(SocketChannelImpl.java:543)
> at kafka.network.BlockingChannel.connect(BlockingChannel.scala:57)
> at kafka.producer.SyncProducer.connect(SyncProducer.scala:146)
> at kafka.producer.SyncProducer.getOrMakeConnection(SyncProducer.scala:161)
> at kafka.producer.SyncProducer.kafka$producer$SyncProducer$$doSend(SyncProducer.scala:68)
> at kafka.producer.SyncProducer.send(SyncProducer.scala:112)
> at kafka.client.ClientUtils$.fetchTopicMetadata(ClientUtils.scala:53)
> at kafka.client.ClientUtils$.fetchTopicMetadata(ClientUtils.scala:88)
> at kafka.consumer.ConsumerFetcherManager$LeaderFinderThread.doWork(ConsumerFetcherManager.scala:64)
> at kafka.utils.ShutdownableThread.run(ShutdownableThread.scala:51)
> [2013-08-12 14:45:20,715] ERROR Producer connection to kafka004:9092 unsuccessful (kafka.producer.SyncProducer)
> java.nio.channels.ClosedByInterruptException
> at java.nio.channels.spi.AbstractInterruptibleChannel.end(AbstractInterruptibleChannel.java:184)
> at sun.nio.ch.SocketChannelImpl.connect(SocketChannelImpl.java:543)
> at kafka.network.BlockingChannel.connect(BlockingChannel.scala:57)
> at kafka.producer.SyncProducer.connect(SyncProducer.scala:146)