Home | About | Sematext search-lucene.com search-hadoop.com
NEW: Monitor These Apps!
elasticsearch, apache solr, apache hbase, hadoop, redis, casssandra, amazon cloudwatch, mysql, memcached, apache kafka, apache zookeeper, apache storm, ubuntu, centOS, red hat, debian, puppet labs, java, senseiDB
 Search Hadoop and all its subprojects:

Switch to Plain View
Kafka >> mail # user >> Re: exception report


Copy link to this message
-
Re: exception report
Hi,

This is possible if the metadata request has several topics. We are working
on making it more efficient. For now, you can increase the value of
request.timeout.ms.

Thanks,
Neha
On May 7, 2013 6:29 AM, "Yu, Libo" <[EMAIL PROTECTED]> wrote:

> Hi,
>
> This exception was thrown after the server was running for about a day.
>
> [2013-05-05 21:53:15,377] WARN Fetching topic metadata with correlation id
> 0 for topics [Set(atest1)] from broker [id:0,host: XXXXXXXX,port:9092]
> failed (kafka.client.ClientUtils$)
> java.net.SocketTimeoutException
>         at
> sun.nio.ch.SocketAdaptor$SocketInputStream.read(SocketAdaptor.java:226)
>         at sun.nio.ch.ChannelInputStream.read(ChannelInputStream.java:103)
>         at
> java.nio.channels.Channels$ReadableByteChannelImpl.read(Channels.java:385)
>         at kafka.utils.Utils$.read(Utils.scala:374)
>         at
> kafka.network.BoundedByteBufferReceive.readFrom(BoundedByteBufferReceive.scala:54)
>         at
> kafka.network.Receive$class.readCompletely(Transmission.scala:56)
>         at
> kafka.network.BoundedByteBufferReceive.readCompletely(BoundedByteBufferReceive.scala:29)
>         at kafka.network.BlockingChannel.receive(BlockingChannel.scala:100)
>         at kafka.producer.SyncProducer.liftedTree1$1(SyncProducer.scala:74)
>         at
> kafka.producer.SyncProducer.kafka$producer$SyncProducer$$doSend(SyncProducer.scala:71)
>         at kafka.producer.SyncProducer.send(SyncProducer.scala:112)
>         at
> kafka.client.ClientUtils$.fetchTopicMetadata(ClientUtils.scala:33)
>         at
> kafka.producer.BrokerPartitionInfo.updateInfo(BrokerPartitionInfo.scala:75)
>         at
> kafka.producer.async.DefaultEventHandler$$anonfun$handle$1.apply$mcV$sp(DefaultEventHandler.scala:68)
>         at kafka.utils.Utils$.swallow(Utils.scala:166)
>         at kafka.utils.Logging$class.swallowError(Logging.scala:106)
>         at kafka.utils.Utils$.swallowError(Utils.scala:45)
>         at
> kafka.producer.async.DefaultEventHandler.handle(DefaultEventHandler.scala:68)
>         at
> kafka.producer.async.ProducerSendThread.tryToHandle(ProducerSendThread.scala:104)
>         at
> kafka.producer.async.ProducerSendThread$$anonfun$processEvents$3.apply(ProducerSendThread.scala:87)
>         at
> kafka.producer.async.ProducerSendThread$$anonfun$processEvents$3.apply(ProducerSendThread.scala:67)
>         at scala.collection.immutable.Stream.foreach(Stream.scala:254)
>         at
> kafka.producer.async.ProducerSendThread.processEvents(ProducerSendThread.scala:66)
>         at
> kafka.producer.async.ProducerSendThread.run(ProducerSendThread.scala:44)
> [2013-05-05 21:53:15,381] INFO Fetching metadata with correlation id 0 for
> 1 topic(s) Set(atest1) (kafka.client.ClientUtils$)
> [2013-05-05 21:53:15,388] INFO Connected to XXXXXXX:9093 for producing
> (kafka.producer.SyncProducer)
> [2013-05-05 21:53:16,282] INFO Disconnecting from XXXXXXX:9093
> (kafka.producer.SyncProducer)
> [2013-05-05 21:53:16,351] INFO Connected to XXXXXXXX:9093 for producing
> (kafka.producer.SyncProducer)
> [2013-05-05 21:53:18,756] INFO Connected to XXXXXXXX:9092 for producing
> (kafka.producer.SyncProducer)
>
> Regards,
>
> Libo
>
>

 
+
Neha Narkhede 2013-05-09, 16:10
+
Chris Curtin 2013-05-09, 16:32
+
Jun Rao 2013-05-13, 16:30
+
David DeMaagd 2013-05-13, 19:50
NEW: Monitor These Apps!
elasticsearch, apache solr, apache hbase, hadoop, redis, casssandra, amazon cloudwatch, mysql, memcached, apache kafka, apache zookeeper, apache storm, ubuntu, centOS, red hat, debian, puppet labs, java, senseiDB