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

Switch to Threaded View
Kafka, mail # user - Re: exception report


Copy link to this message
-
Re: exception report
Neha Narkhede 2013-05-07, 14:06
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
>
>