Everytime I try to execute commands from the Consumer Manager set I get the following error:
Traceback (most recent call last):
File "/usr/local/bin/kafka-consumer-manager", line 6, in <module>
run()
File "/usr/local/lib/python3.6/site-packages/kafka_utils/kafka_consumer_manager/main.py", line 121, in run
args.command(args, conf)
File "/usr/local/lib/python3.6/site-packages/kafka_utils/kafka_consumer_manager/commands/list_topics.py", line 57, in run
fail_on_error=False,
File "/usr/local/lib/python3.6/site-packages/kafka_utils/kafka_consumer_manager/commands/offset_manager.py", line 82, in preprocess_args
groupid,
File "/usr/local/lib/python3.6/site-packages/kafka_utils/kafka_consumer_manager/commands/offset_manager.py", line 37, in get_topics_from_consumer_group_id
return cls.get_topics_for_group_from_kafka(cluster_config, groupid)
File "/usr/local/lib/python3.6/site-packages/kafka_utils/kafka_consumer_manager/commands/offset_manager.py", line 147, in get_topics_for_group_from_kafka
group_topics = kafka_group_reader.read_group(groupid)
File "/usr/local/lib/python3.6/site-packages/kafka_utils/kafka_consumer_manager/util.py", line 270, in read_group
return self.read_groups(partition).get(group_id, [])
File "/usr/local/lib/python3.6/site-packages/kafka_utils/kafka_consumer_manager/util.py", line 322, in read_groups
self.process_consumer_offset_message(message)
File "/usr/local/lib/python3.6/site-packages/kafka_utils/kafka_consumer_manager/util.py", line 382, in process_consumer_offset_message
group, topic, partition, offset = self.parse_consumer_offset_message(message)
File "/usr/local/lib/python3.6/site-packages/kafka_utils/kafka_consumer_manager/util.py", line 367, in parse_consumer_offset_message
(group, cur) = read_short_string(key, cur)
File "/usr/local/lib/python3.6/site-packages/kafka/util.py", line 51, in read_short_string
raise BufferUnderflowError("Not enough data left")
kafka.errors.BufferUnderflowError: BufferUnderflowError: Not enough data left
Everytime I try to execute commands from the
Consumer Manager
set I get the following error:Any suggestions why this error occurs?