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


Copy link to this message
-
Re: Runtime problem in 8 beta1?
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
 
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