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...@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 > >
