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

 
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