It seems we don't pack the dependencies in phoenix-kafka jar yet. Try including flume-ng-configuration-1.3.0.jar in your classpath to resolve the above issue.
On Thu, Apr 20, 2017 at 9:27 AM, lk_phoenix <[email protected]> wrote: > hi,all: > I try to read data from kafka_2.11-0.10.2.0 , I get error: > > Exception in thread "main" java.lang.NoClassDefFoundError: > org/apache/flume/Context > at org.apache.phoenix.kafka.consumer.PhoenixConsumer.prepareContext( > PhoenixConsumer.java:140) > at org.apache.phoenix.kafka.consumer.PhoenixConsumer.< > init>(PhoenixConsumer.java:71) > at org.apache.phoenix.kafka.consumer.PhoenixConsumerTool. > run(PhoenixConsumerTool.java:98) > at org.apache.hadoop.util.ToolRunner.run(ToolRunner.java:70) > at org.apache.hadoop.util.ToolRunner.run(ToolRunner.java:84) > at org.apache.phoenix.kafka.consumer.PhoenixConsumerTool. > main(PhoenixConsumerTool.java:104) > at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method) > at sun.reflect.NativeMethodAccessorImpl.invoke( > NativeMethodAccessorImpl.java:62) > at sun.reflect.DelegatingMethodAccessorImpl.invoke( > DelegatingMethodAccessorImpl.java:43) > at java.lang.reflect.Method.invoke(Method.java:498) > at org.apache.hadoop.util.RunJar.run(RunJar.java:221) > at org.apache.hadoop.util.RunJar.main(RunJar.java:136) > Caused by: java.lang.ClassNotFoundException: org.apache.flume.Context > at java.net.URLClassLoader.findClass(URLClassLoader.java:381) > at java.lang.ClassLoader.loadClass(ClassLoader.java:424) > at java.lang.ClassLoader.loadClass(ClassLoader.java:357) > ... 12 more > how to import flume Context ? > > I follow this http://phoenix.apache.org/kafka.html tutorials. > > 2017-04-20 > ------------------------------ > lk_phoenix >
