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 # dev >> Runtime problem in 8 beta1?


+
David Williams 2013-08-27, 02:10
+
Jay Kreps 2013-08-27, 03:35
+
David Williams 2013-08-27, 04:16
+
Benjamin Black 2013-08-27, 04:33
+
Joe Stein 2013-08-27, 04:34
+
David Williams 2013-08-27, 16:41
+
Joe Stein 2013-08-27, 16:46
+
David Williams 2013-08-27, 16:55
+
David Williams 2013-08-27, 18:11
+
David Williams 2013-08-27, 18:14
+
Benjamin Black 2013-08-27, 18:16
+
David Williams 2013-08-27, 18:18
+
David Williams 2013-08-27, 18:25
Copy link to this message
-
Re: Runtime problem in 8 beta1?
David, you could see that error message when the Kafka broker is not
running.

Give the quick start a shot
http://kafka.apache.org/documentation.html#quickstart and make sure that
everything is working end to end with a producer and consumer and then hook
up your code for first pass to help eliminate causes.

/*******************************************
 Joe Stein
 Founder, Principal Consultant
 Big Data Open Source Security LLC
 http://www.stealth.ly
 Twitter: @allthingshadoop <http://www.twitter.com/allthingshadoop>
********************************************/
On Tue, Aug 27, 2013 at 2:24 PM, David Williams <[EMAIL PROTECTED]>wrote:

> All,
>
> Sorry for this continued thread, but this is day 2 of no success making a
> kafka example app:
>
>
> I added the dependency
>
>
> <dependency>
>             <groupId>com.yammer.metrics</groupId>
>             <artifactId>metrics-core</artifactId>
>             <version>2.2.0</version>
>         </dependency>
>
>
>
> But this unearths yet another exception:
>
> Exception in thread "main" java.lang.reflect.InvocationTargetException
>         at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
>         at
> sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:5
> 7)
>         at
> sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImp
> l.java:43)
>         at java.lang.reflect.Method.invoke(Method.java:606)
>         at com.simontuffs.onejar.Boot.run(Boot.java:340)
>         at com.simontuffs.onejar.Boot.main(Boot.java:166)
> Caused by: kafka.common.ConsumerRebalanceFailedException:
> inventory_broadways-MacBook-Pro-4.local-1377627595697-772e9707 can't
> rebalance after 4 retries
>         at
> kafka.consumer.ZookeeperConsumerConnector$ZKRebalancerListener.syncedRebala
> nce(ZookeeperConsumerConnector.scala:397)
>         at
> kafka.consumer.ZookeeperConsumerConnector.kafka$consumer$ZookeeperConsumerC
> onnector$$reinitializeConsumer(ZookeeperConsumerConnector.scala:681)
>         at
> kafka.consumer.ZookeeperConsumerConnector.consume(ZookeeperConsumerConnecto
> r.scala:205)
>         at
> kafka.javaapi.consumer.ZookeeperConsumerConnector.createMessageStreams(Zook
> eeperConsumerConnector.scala:77)
>         at
> kafka.javaapi.consumer.ZookeeperConsumerConnector.createMessageStreams(Zook
> eeperConsumerConnector.scala:89)
>
>
>
> What is this?
>
>
>
> --
>
>
>
>
>
>
> On 8/27/13 11:18 AM, "David Williams" <[EMAIL PROTECTED]> wrote:
>
> >This resulted in
> >
> >Exception in thread "main" java.lang.reflect.InvocationTargetException
> >        at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
> >        at
> >sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:
> >5
> >7)
> >        at
> >sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorIm
> >p
> >l.java:43)
> >        at java.lang.reflect.Method.invoke(Method.java:606)
> >        at com.simontuffs.onejar.Boot.run(Boot.java:340)
> >        at com.simontuffs.onejar.Boot.main(Boot.java:166)
> >Caused by: java.lang.NoClassDefFoundError: com/yammer/metrics/core/Gauge
> >        at
> >kafka.consumer.ZookeeperConsumerConnector.createFetcher(ZookeeperConsumerC
> >o
> >nnector.scala:146)
> >        at
> >kafka.consumer.ZookeeperConsumerConnector.<init>(ZookeeperConsumerConnecto
> >r
> >.scala:113)
> >        at
> >kafka.javaapi.consumer.ZookeeperConsumerConnector.<init>(ZookeeperConsumer
> >C
> >onnector.scala:64)
> >        at
> >kafka.javaapi.consumer.ZookeeperConsumerConnector.<init>(ZookeeperConsumer
> >C
> >onnector.scala:66)
> >        at
> >kafka.consumer.Consumer$.createJavaConsumerConnector(ConsumerConnector.sca
> >l
> >a:100)
> >        at
> >kafka.consumer.Consumer.createJavaConsumerConnector(ConsumerConnector.scal
> >a
> >)
> >
> >
> >
> >
> >--
> >
> >
> >
> >
> >
> >
> >On 8/27/13 11:14 AM, "Benjamin Black" <[EMAIL PROTECTED]> wrote:
> >
> >>I've been using the Maven package without issue. Of course, I'm not using
> >>Spring, either. Here's the relevant section from a working pom:

 
+
David Williams 2013-08-27, 18:40
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