kafka-users mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Neha Narkhede <neha.narkh...@gmail.com>
Subject Re: exception report
Date Tue, 07 May 2013 14:06:05 GMT
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" <libo.yu@citi.com> 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
>
>

Mime
  • Unnamed multipart/alternative (inline, None, 0 bytes)
View raw message