Home | About | Sematext search-lucene.com search-hadoop.com
NEW: Monitor These Apps!
elasticsearch, apache solr, apache hbase, hadoop, redis, casssandra, amazon cloudwatch, mysql, memcached, apache kafka, apache zookeeper, apache storm, ubuntu, centOS, red hat, debian, puppet labs, java, senseiDB
 Search Hadoop and all its subprojects:

Switch to Plain View
Kafka >> mail # user >> [0.8] exception running on windows when attempting to send to an uncreated topic


Copy link to this message
-
[0.8] exception running on windows when attempting to send to an uncreated topic
I am running on windows.  I am programmatically (no scripts) starting a zk,
2 brokers, 2 consumers and a producer, in this order but the first 3 at
once, then the other 3 at once, all with a nonexistent topic.

 

Here's the pertinent log for the producer (with other stuff mixed in, no
doubt):

 

start production: com.dish.des.msgs.notifications.StartProduction@d27b1b3

{2013-05-08 23:53:07,187}  INFO [local-vat] (Logging.scala:67) - Fetching
metadata with correlation id 0 for 1 topic(s) Set(robert_v_2x0)

{2013-05-08 23:53:07,206} DEBUG [local-vat] (Logging.scala:51) - Created
socket with SO_TIMEOUT = 1500 (requested 1500), SO_RCVBUF = 8192 (requested
-1), SO_SNDBUF = 102400 (requested 102400).

{2013-05-08 23:53:07,207} DEBUG [kafka-acceptor] (Logging.scala:51) -
Accepted connection from /127.0.0.1 on /127.0.0.1:9092. sendBufferSize
[actual|requested]: [1048576|1048576] recvBufferSize [actual|requested]:
[1048576|1048576]

{2013-05-08 23:53:07,208} DEBUG [kafka-processor-9092-0] (Logging.scala:51)
- Processor 0 listening to new connection from /127.0.0.1:63245

{2013-05-08 23:53:07,209}  INFO [local-vat] (Logging.scala:67) - Connected
to localhost:9092 for producing

{2013-05-08 23:53:07,256} DEBUG [SyncThread:0]
(FinalRequestProcessor.java:78) - Processing request::
sessionid:0x13e87d872090002 type:ping cxid:0xfffffffffffffffe
zxid:0xfffffffffffffffe txntype:unknown reqpath:n/a

{2013-05-08 23:53:07,256} DEBUG [SyncThread:0]
(FinalRequestProcessor.java:160) - sessionid:0x13e87d872090002 type:ping
cxid:0xfffffffffffffffe zxid:0xfffffffffffffffe txntype:unknown reqpath:n/a

{2013-05-08 23:53:07,257} DEBUG [main-SendThread(localhost:2181)]
(ClientCnxn.java:758) - Got ping response for sessionid: 0x13e87d872090002
after 2ms

{2013-05-08 23:53:07,279} DEBUG [kafka-request-handler-1] (Logging.scala:51)
- [Kafka Request Handler 1 on Broker 0], handles request
Request(0,sun.nio.ch.SelectionKeyImpl@1261db2b,null,1368078787227,/127.0.0.1
:63245)

{2013-05-08 23:53:07,290} DEBUG [SyncThread:0]
(FinalRequestProcessor.java:78) - Processing request::
sessionid:0x13e87d872090000 type:exists cxid:0x26 zxid:0xfffffffffffffffe
txntype:unknown reqpath:/brokers/topics/robert_v_2x0

{2013-05-08 23:53:07,291} DEBUG [SyncThread:0]
(FinalRequestProcessor.java:160) - sessionid:0x13e87d872090000 type:exists
cxid:0x26 zxid:0xfffffffffffffffe txntype:unknown
reqpath:/brokers/topics/robert_v_2x0

{2013-05-08 23:53:07,293} DEBUG [Thread-1-SendThread(localhost:2181)]
(ClientCnxn.java:838) - Reading reply sessionid:0x13e87d872090000, packet::
clientPath:null serverPath:null finished:false header:: 38,3  replyHeader::
38,955,-101  request:: '/brokers/topics/robert_v_2x0,F  response::  

{2013-05-08 23:53:07,373} ERROR [kafka-request-handler-1]
(Logging.scala:102) - [KafkaApi-0] Error while retrieving topic metadata

java.lang.NoClassDefFoundError: joptsimple/OptionSpec

       at
kafka.server.KafkaApis$$anonfun$handleTopicMetadataRequest$1.apply(KafkaApis
.scala:411)

       at
kafka.server.KafkaApis$$anonfun$handleTopicMetadataRequest$1.apply(KafkaApis
.scala:403)

       at scala.collection.immutable.Set$Set1.foreach(Set.scala:81)

       at
kafka.server.KafkaApis.handleTopicMetadataRequest(KafkaApis.scala:402)

       at kafka.server.KafkaApis.handle(KafkaApis.scala:63)

       at kafka.server.KafkaRequestHandler.run(KafkaRequestHandler.scala:41)

       at java.lang.Thread.run(Thread.java:722)

Caused by: java.lang.ClassNotFoundException: joptsimple.OptionSpec

       at java.net.URLClassLoader$1.run(URLClassLoader.java:366)

       at java.net.URLClassLoader$1.run(URLClassLoader.java:355)

       at java.security.AccessController.doPrivileged(Native Method)

       at java.net.URLClassLoader.findClass(URLClassLoader.java:354)

       at java.lang.ClassLoader.loadClass(ClassLoader.java:423)

       at sun.misc.Launcher$AppClassLoader.loadClass(Launcher.java:308)

       at java.lang.ClassLoader.loadClass(ClassLoader.java:356)

       ... 7 more

{2013-05-08 23:53:07,388} DEBUG [SyncThread:0]
(FinalRequestProcessor.java:78) - Processing request::
sessionid:0x13e87d872090003 type:ping cxid:0xfffffffffffffffe
zxid:0xfffffffffffffffe txntype:unknown reqpath:n/a

{2013-05-08 23:53:07,393} DEBUG [SyncThread:0]
(FinalRequestProcessor.java:160) - sessionid:0x13e87d872090003 type:ping
cxid:0xfffffffffffffffe zxid:0xfffffffffffffffe txntype:unknown reqpath:n/a

{2013-05-08 23:53:07,395} DEBUG [main-SendThread(localhost:2181)]
(ClientCnxn.java:758) - Got ping response for sessionid: 0x13e87d872090003
after 8ms

{2013-05-08 23:53:07,557}  INFO [local-vat] (Logging.scala:67) -
Disconnecting from localhost:9092

{2013-05-08 23:53:07,570} DEBUG [local-vat] (Logging.scala:51) -
Successfully fetched metadata for 1 topic(s) Set(robert_v_2x0)

{2013-05-08 23:53:07,583} DEBUG [local-vat] (Logging.scala:51) - Getting
broker partition info for topic robert_v_2x0

{2013-05-08 23:53:07,600}  INFO [local-vat] (Logging.scala:67) - Fetching
metadata with correlation id 1 for 1 topic(s) Set(robert_v_2x0)

{2013-05-08 23:53:07,605} DEBUG [kafka-acceptor] (Logging.scala:51) -
Accepted connection from /127.0.0.1 on /127.0.0.1:9092. sendBufferSize
[actual|requested]: [1048576|1048576] recvBufferSize [actual|requested]:
[1048576|1048576]

{2013-05-08 23:53:07,606} DEBUG [kafka-processor-9092-1] (Logging.scala:51)
- Processor 1 listening to new connection from /127.0.0.1:63248

{2013-05-08 23:53:07,588}  INFO [kafka-processor-9092-0] (Logging.scala:67)
- Closing socket connection to /127.0.0.1.

{2013-05-08 23:53:07,609} DEBUG [kafka-processor-9092-0] (Logging.scala:51)
- Closing connection from /127.0.0.1:63245

{2013-05-08 23:53:07,606} DEBUG [SyncThread:0]
(FinalRequestProcessor.java:78) - Processing request::
sessionid:0x13e87d872090001 type:ping cxid:0xfffffffffffffffe
zxid:0xfffffffffffffffe txntype:unknown reqpath:n/a

{2013-05-08 23:53:07,618} DEBUG [SyncThread:0]
(FinalRequestProcessor.java:160) - sessionid:0x13e87d872090001 type:ping
c
+
Jun Rao 2013-05-09, 15:00
+
Rob Withers 2013-05-11, 00:38
+
Jun Rao 2013-05-11, 04:54
+
Rob Withers 2013-05-11, 04:57
+
Rob Withers 2013-05-10, 06:28
+
Jun Rao 2013-05-10, 15:58
NEW: Monitor These Apps!
elasticsearch, apache solr, apache hbase, hadoop, redis, casssandra, amazon cloudwatch, mysql, memcached, apache kafka, apache zookeeper, apache storm, ubuntu, centOS, red hat, debian, puppet labs, java, senseiDB