You signed in with another tab or window. Reload to refresh your session.You signed out in another tab or window. Reload to refresh your session.You switched accounts on another tab or window. Reload to refresh your session.Dismiss alert
{{ message }}
This repository has been archived by the owner on Aug 29, 2023. It is now read-only.
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
Any suggestions why this error occurs?
The text was updated successfully, but these errors were encountered:
Sign up for freeto subscribe to this conversation on GitHub.
Already have an account?
Sign in.
Everytime I try to execute commands from the
Consumer Manager
set I get the following error:Any suggestions why this error occurs?
The text was updated successfully, but these errors were encountered: