Yelp/kafka-utils

BufferUnderflowError: Not enough data left

Opened this issue · 0 comments

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?