Home | About | Sematext search-lucene.com search-hadoop.com
 Search Hadoop and all its subprojects:

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


Copy link to this message
-
Re: [0.8] exception running on windows when attempting to send to an uncreated topic
You are missing the jopt-simple jar.

Thanks,

Jun
On Wed, May 8, 2013 at 11:03 PM, Rob Withers <[EMAIL PROTECTED]> wrote:

> 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)