It seems like the following Class is being referred by the 'shutdown' function:
kafka.admin.ShutdownBroker
Which is non-existent on Kafka versions > 0.8.1.1:
0.8.1.1:
$ ls /tmp/kafka_2.10-0.8.1.1/libs*.jar|xargs -I INPUT jar tvf INPUT |grep -i 'kafka/admin/ShutdownBroker\.class' 4650 Tue Apr 22 19:25:10 UTC 2014 kafka/admin/ShutdownBroker.class $
0.11.0.0:
$ ls /tmp/kafka_2.11-0.11.0.0/libs*.jar|xargs -I INPUT jar tvf INPUT |grep -i 'kafka/admin/ShutdownBroker\.class' $
Causing:
Error: Could not find or load main class kafka.admin.ShutdownBroker
While running kafkat with any version of Kafka higher than 0.8.1.1.
It seems like the following Class is being referred by the 'shutdown' function:
kafka.admin.ShutdownBrokerWhich is non-existent on Kafka versions > 0.8.1.1:
0.8.1.1:
$ ls /tmp/kafka_2.10-0.8.1.1/libs*.jar|xargs -I INPUT jar tvf INPUT |grep -i 'kafka/admin/ShutdownBroker\.class' 4650 Tue Apr 22 19:25:10 UTC 2014 kafka/admin/ShutdownBroker.class $0.11.0.0:
$ ls /tmp/kafka_2.11-0.11.0.0/libs*.jar|xargs -I INPUT jar tvf INPUT |grep -i 'kafka/admin/ShutdownBroker\.class' $Causing:
Error: Could not find or load main class kafka.admin.ShutdownBrokerWhile running
kafkatwith any version of Kafka higher than 0.8.1.1.