kafka-console-consumer.sh --topic TOPIC_KEYWORD --from-beginning --zookeeper localhost
报异常,Exception in thread "main" java.lang.NoSuchMethodError: kafka.utils.CommandLineUtils$.parseKeyValueArgs(Lscala/collection/Iterable;)Ljava/util/Properties;
at kafka.tools.ConsoleConsumer$.main(ConsoleConsumer.scala:143)
at kafka.tools.ConsoleConsumer.main(ConsoleConsumer.scala)
同样的kafka-console-producer.sh 也会报同样的异常,
显示是找不到类,应该是CLASSPATH 可能会有问题,
检查全局或当前的环境变量可能有值冲突了KAFKA的环境变量,比如我的问题是我把一个KAFKAMONITOR的JAR包放到环境变量CLASSPATH里面了,
这样它去找的时候找这个包,却没有找到它需要的值.所以修改这个环境变量即中.