kafka-users mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From "Yu, Libo " <libo...@citi.com>
Subject exception report
Date Tue, 07 May 2013 13:28:38 GMT
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