Details
-
Bug
-
Status: Patch Available
-
Trivial
-
Resolution: Unresolved
-
4.13.0
-
None
-
None
-
the Phoenix Kafka plugin webpage has incomplete example for filling out consumer properties files.
Description
getting the following message
Exception in thread "main" org.apache.kafka.common.config.ConfigException: Missing required configuration "partition.assignment.strategy" which has no default value. at org.apache.kafka.common.config.ConfigDef.parse(ConfigDef.java:124) at org.apache.kafka.common.config.AbstractConfig.<init>(AbstractConfig.java:48) at org.apache.kafka.clients.consumer.ConsumerConfig.<init>(ConsumerConfig.java:194) at org.apache.kafka.clients.consumer.KafkaConsumer.<init>(KafkaConsumer.java:430) at org.apache.kafka.clients.consumer.KafkaConsumer.<init>(KafkaConsumer.java:413) at org.apache.kafka.clients.consumer.KafkaConsumer.<init>(KafkaConsumer.java:400) at org.apache.phoenix.kafka.consumer.PhoenixConsumer.intializeKafka(PhoenixConsumer.java:128) at org.apache.phoenix.kafka.consumer.PhoenixConsumer.intializeKafka(PhoenixConsumer.java:99) at org.apache.phoenix.kafka.consumer.PhoenixConsumer.<init>(PhoenixConsumer.java:68) at org.apache.phoenix.kafka.consumer.PhoenixConsumerTool.run(PhoenixConsumerTool.java:98) at org.apache.hadoop.util.ToolRunner.run(ToolRunner.java:76) at org.apache.hadoop.util.ToolRunner.run(ToolRunner.java:90) 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:239) at org.apache.hadoop.util.RunJar.main(RunJar.java:153)