Home | About | Sematext search-lucene.com search-hadoop.com
 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
+
Joe Stein 2013-08-27, 18:35
Copy link to this message
-
Re: Runtime problem in 8 beta1?
David Williams 2013-08-27, 18:40
Excellent Joe, thanks, good to go :)

--
On 8/27/13 11:35 AM, "Joe Stein" <[EMAIL PROTECTED]> wrote:

>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(DelegatingMethodAccessorI
>>mp
>> 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.syncedReba
>>la
>> nce(ZookeeperConsumerConnector.scala:397)
>>         at
>>
>>kafka.consumer.ZookeeperConsumerConnector.kafka$consumer$ZookeeperConsume
>>rC
>> onnector$$reinitializeConsumer(ZookeeperConsumerConnector.scala:681)
>>         at
>>
>>kafka.consumer.ZookeeperConsumerConnector.consume(ZookeeperConsumerConnec
>>to
>> r.scala:205)
>>         at
>>
>>kafka.javaapi.consumer.ZookeeperConsumerConnector.createMessageStreams(Zo
>>ok
>> eeperConsumerConnector.scala:77)
>>         at
>>
>>kafka.javaapi.consumer.ZookeeperConsumerConnector.createMessageStreams(Zo
>>ok
>> 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.jav
>>>a:
>> >5
>> >7)
>> >        at
>>
>>>sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessor
>>>Im
>> >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(ZookeeperConsume
>>>rC
>> >o
>> >nnector.scala:146)
>> >        at
>>
>>>kafka.consumer.ZookeeperConsumerConnector.<init>(ZookeeperConsumerConnec
>>>to
>> >r
>> >.scala:113)
>> >        at
>>
>>>kafka.javaapi.consumer.ZookeeperConsumerConnector.<init>(ZookeeperConsum
>>>er
>> >C
>> >onnector.scala:64)
>> >        at
>>
>>>kafka.javaapi.consumer.ZookeeperConsumerConnector.<init>(ZookeeperConsum
>>>er
>> >C
>> >onnector.scala:66)
>> >        at
>>
>>>kafka.consumer.Consumer$.createJavaConsumerConnector(ConsumerConnector.s
>>>ca
>> >l