Open jjmleiro opened 9 years ago
When Apache Kafka version is 0.8.1 or higher, replace in line 33:
parser.add_argument('-K','--kafka_list_bin',action='store',default='/usr/lib/kafka/bin/kafka-list-topic.sh')
for
parser.add_argument('-K','--kafka_list_bin',action='store',default='/usr/lib/kafka/bin/kafka-topics.sh')
When Apache Kafka version is 0.8.1 or higher, replace in line 33:
parser.add_argument('-K','--kafka_list_bin',action='store',default='/usr/lib/kafka/bin/kafka-list-topic.sh')
for
parser.add_argument('-K','--kafka_list_bin',action='store',default='/usr/lib/kafka/bin/kafka-topics.sh')