Support Questions
Find answers, ask questions, and share your expertise
Announcements
Alert: Welcome to the Unified Cloudera Community. Former HCC members be sure to read and learn how to activate your account here.

Apache kafka plugin using Phoenix-consumer API

Highlighted

Apache kafka plugin using Phoenix-consumer API

Contributor

Hi Team, In my use case we are going to implement Apache Kafka Plugin, i have gone through the site how to deploy this scenerio (https://phoenix.apache.org/kafka.html), but when trying this command, i need to know what should be specified in phoenix-kafka-<version>-minimal.jar to run this command Command :- HADOOP_CLASSPATH=$(hbase classpath):/path/to/hbase/conf hadoop jar phoenix-kafka-<version>-minimal.jar org.apache.phoenix.kafka.consumer.PhoenixConsumerTool --file /data/kafka-consumer.properties Please suggest what should be specified in this jar, whether path or i need to install jar.if so, please provide the link of jar file.

2 REPLIES 2

Re: Apache kafka plugin using Phoenix-consumer API

Mentor

The Phoenix Kafka plugin is not released in HDP, please refer to https://issues.apache.org/jira/browse/PHOENIX-3214 for details on running the plugin.

Highlighted

Re: Apache kafka plugin using Phoenix-consumer API

New Contributor

we just need to put phoenx-kafka-***-minimal jar file available in binary distribution of appropriate phoenix version which need to downloaded and extracted to hbase CLASSPATH. and then excute the command as it is. pointing to the jar file copied. 

Don't have an account?
Coming from Hortonworks? Activate your account here