From users-return-4275-apmail-kafka-users-archive=kafka.apache.org@kafka.apache.org Tue May 7 13:29:40 2013 Return-Path: X-Original-To: apmail-kafka-users-archive@www.apache.org Delivered-To: apmail-kafka-users-archive@www.apache.org Received: from mail.apache.org (hermes.apache.org [140.211.11.3]) by minotaur.apache.org (Postfix) with SMTP id DE8E510635 for ; Tue, 7 May 2013 13:29:40 +0000 (UTC) Received: (qmail 53722 invoked by uid 500); 7 May 2013 13:29:40 -0000 Delivered-To: apmail-kafka-users-archive@kafka.apache.org Received: (qmail 53504 invoked by uid 500); 7 May 2013 13:29:40 -0000 Mailing-List: contact users-help@kafka.apache.org; run by ezmlm Precedence: bulk List-Help: List-Unsubscribe: List-Post: List-Id: Reply-To: users@kafka.apache.org Delivered-To: mailing list users@kafka.apache.org Received: (qmail 53495 invoked by uid 99); 7 May 2013 13:29:40 -0000 Received: from nike.apache.org (HELO nike.apache.org) (192.87.106.230) by apache.org (qpsmtpd/0.29) with ESMTP; Tue, 07 May 2013 13:29:40 +0000 X-ASF-Spam-Status: No, hits=1.5 required=5.0 tests=HTML_MESSAGE,RCVD_IN_DNSWL_LOW,SPF_PASS X-Spam-Check-By: apache.org Received-SPF: pass (nike.apache.org: domain of libo.yu@citi.com designates 67.231.153.94 as permitted sender) Received: from [67.231.153.94] (HELO mx0b-00123c01.pphosted.com) (67.231.153.94) by apache.org (qpsmtpd/0.29) with ESMTP; Tue, 07 May 2013 13:29:30 +0000 Received: from pps.filterd (m0008247 [127.0.0.1]) by mx0b-00123c02.pphosted.com (8.14.5/8.14.5) with SMTP id r47DOhAu020102 for ; Tue, 7 May 2013 13:29:09 GMT Received: from mail.citigroup.com ([192.193.220.6]) by mx0b-00123c02.pphosted.com with ESMTP id 1buqph76nv-1 (version=TLSv1/SSLv3 cipher=AES256-SHA bits=256 verify=NOT) for ; Tue, 07 May 2013 13:29:09 +0000 Received: from imbhub-sw11.nam.nsroot.net (namdlpdimpgt06.nam.nsroot.net [169.193.226.15]) by smtpinbound.citigroup.com (Switch-3.4.1/Switch-3.4.1) with ESMTP id r47DSTp6022999 for ; Tue, 7 May 2013 13:29:08 GMT Received: from exnjiht01.nam.nsroot.net (EXNJIHT01.nam.nsroot.net [150.110.165.227]) by imbhub-sw11.nam.nsroot.net (Switch-3.4.1/Switch-3.4.1) with ESMTP id r47DPxZW004001 for ; Tue, 7 May 2013 13:29:04 GMT Received: from EXNJHT10.nam.nsroot.net (150.110.191.51) by exnjiht01.nam.nsroot.net (150.110.165.227) with Microsoft SMTP Server (TLS) id 8.3.264.0; Tue, 7 May 2013 09:28:41 -0400 Received: from EXTXHT06.nam.nsroot.net (169.177.87.43) by EXNJHT10.nam.nsroot.net (150.110.191.51) with Microsoft SMTP Server (TLS) id 14.2.328.9; Tue, 7 May 2013 09:28:40 -0400 Received: from EXTXMB17.nam.nsroot.net ([169.254.2.132]) by EXTXHT06.nam.nsroot.net ([169.177.87.43]) with mapi id 14.02.0328.009; Tue, 7 May 2013 08:28:39 -0500 From: "Yu, Libo " To: "'users@kafka.apache.org'" Subject: exception report Thread-Topic: exception report Thread-Index: Ac5LJsgiD1P7QQxKSOSX6KJx+PS3Mw== Date: Tue, 7 May 2013 13:28:38 +0000 Message-ID: Accept-Language: en-US Content-Language: en-US X-MS-Has-Attach: X-MS-TNEF-Correlator: x-originating-ip: [169.177.87.242] Content-Type: multipart/alternative; boundary="_000_FF142F6B499AE34CAED4D263F6CA329014AF09A7EXTXMB17namnsro_" MIME-Version: 1.0 X-WiganSS: 01000000010017EXNJHT10.nam.nsroot.net ID0042 X-CFilter-Loop: Reflected X-Proofpoint-Virus-Version: vendor=fsecure engine=2.50.10432:5.10.8626,1.0.431,0.0.0000 definitions=2013-05-07_05:2013-05-07,2013-05-07,1970-01-01 signatures=0 X-Virus-Checked: Checked by ClamAV on apache.org --_000_FF142F6B499AE34CAED4D263F6CA329014AF09A7EXTXMB17namnsro_ Content-Type: text/plain; charset="us-ascii" Content-Transfer-Encoding: quoted-printable 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] fail= ed (kafka.client.ClientUtils$) java.net.SocketTimeoutException at sun.nio.ch.SocketAdaptor$SocketInputStream.read(SocketAdaptor.ja= va: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(BoundedByteBuffe= rReceive.scala:54) at kafka.network.Receive$class.readCompletely(Transmission.scala:56= ) at kafka.network.BoundedByteBufferReceive.readCompletely(BoundedByt= eBufferReceive.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:3= 3) at kafka.producer.BrokerPartitionInfo.updateInfo(BrokerPartitionInf= o.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(DefaultEventHand= ler.scala:68) at kafka.producer.async.ProducerSendThread.tryToHandle(ProducerSend= Thread.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(ProducerSe= ndThread.scala:66) at kafka.producer.async.ProducerSendThread.run(ProducerSendThread.s= cala: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 (kaf= ka.producer.SyncProducer) [2013-05-05 21:53:16,282] INFO Disconnecting from XXXXXXX:9093 (kafka.produ= cer.SyncProducer) [2013-05-05 21:53:16,351] INFO Connected to XXXXXXXX:9093 for producing (ka= fka.producer.SyncProducer) [2013-05-05 21:53:18,756] INFO Connected to XXXXXXXX:9092 for producing (ka= fka.producer.SyncProducer) Regards, Libo --_000_FF142F6B499AE34CAED4D263F6CA329014AF09A7EXTXMB17namnsro_--