Hi Terence, Thanks for your response.
1 . I gave up on using CDAP kafka to create topic, so instead what I did is started an new zookeeper and kafka at 2182 and 9093. I believe that should be fine.
3. add a missing log4j dependecy and build that package as is , but for version CDAp 3.5.1
4. When I start the flow "start flow KafkaIngestionApp.KafkaIngestionFlow", I get a null pointer
I just want to build and run a simple kafka-application on CDAP 3.5.1 ... thanks for you help
2016-09-24 13:50:40,030 - INFO [FlowletRuntimeService STARTING:c.c.c.i.a.r.f.FlowletRuntimeService@119] - Flowlet initialized: flowlet=kafkaConsumer, instance=0, groupsize=1, namespaceId=default, applicationId=KafkaIngestionApp, program=KafkaIngestionFlow, runid=dfdf94c7-825d-11e6-9c86-080027e799c9
2016-09-24 13:50:40,660 - WARN [FlowletProcessDriver-kafkaConsumer-0-executor:c.c.c.i.a.r.f.FlowletProcessDriver@364] - Process failure: flowlet=kafkaConsumer, instance=0, groupsize=1, namespaceId=default, applicationId=KafkaIngestionApp, program=KafkaIngestionFlow, runid=dfdf94c7-825d-11e6-9c86-080027e799c9, null, input: NullInputDatum{retries=0}
java.lang.NullPointerException: null
at co.cask.cdap.kafka.flow.KafkaConsumerFlowlet$4.apply(KafkaConsumerFlowlet.java:390) ~[cdap-kafka-flow-core-0.9.0.jar:na]
at co.cask.cdap.kafka.flow.KafkaConsumerFlowlet$4.apply(KafkaConsumerFlowlet.java:387) ~[cdap-kafka-flow-core-0.9.0.jar:na]
at co.cask.cdap.kafka.flow.KafkaConsumerFlowlet.decodeKey(KafkaConsumerFlowlet.java:275) ~[cdap-kafka-flow-core-0.9.0.jar:na]
at co.cask.cdap.kafka.flow.KafkaConsumerFlowlet.processMessage(KafkaConsumerFlowlet.java:246) ~[cdap-kafka-flow-core-0.9.0.jar:na]
at co.cask.cdap.kafka.flow.KafkaConsumerFlowlet.pollMessages(KafkaConsumerFlowlet.java:144) ~[cdap-kafka-flow-core-0.9.0.jar:na]
at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method) ~[na:1.7.0_75]
at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:57) ~[na:1.7.0_75]
at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43) ~[na:1.7.0_75]
at java.lang.reflect.Method.invoke(Method.java:606) ~[na:1.7.0_75]
at co.cask.cdap.internal.app.runtime.flow.ReflectionProcessMethod.invoke(ReflectionProcessMethod.java:95) ~[co.cask.cdap.cdap-app-fabric-3.5.1.jar:na]
at co.cask.cdap.internal.app.runtime.flow.FlowletProcessDriver.handleProcessEntry(FlowletProcessDriver.java:246) [co.cask.cdap.cdap-app-fabric-3.5.1.jar:na]
at co.cask.cdap.internal.app.runtime.flow.FlowletProcessDriver.access$000(FlowletProcessDriver.java:61) [co.cask.cdap.cdap-app-fabric-3.5.1.jar:na]
at co.cask.cdap.internal.app.runtime.flow.FlowletProcessDriver$1.run(FlowletProcessDriver.java:194) [co.cask.cdap.cdap-app-fabric-3.5.1.jar:na]
at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:471) [na:1.7.0_75]
at java.util.concurrent.FutureTask.run(FutureTask.java:262) [na:1.7.0_75]
at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1145) [na:1.7.0_75]
at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:615) [na:1.7.0_75]
at java.lang.Thread.run(Thread.java:745) [na:1.7.0_75]