Skip to content
This repository was archived by the owner on Aug 29, 2023. It is now read-only.
This repository was archived by the owner on Aug 29, 2023. It is now read-only.

BufferUnderflowError: Not enough data left #254

@ezienecker

Description

@ezienecker

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?

Metadata

Metadata

Assignees

No one assigned

    Labels

    No labels
    No labels

    Type

    No type

    Projects

    No projects

    Milestone

    No milestone

    Relationships

    None yet

    Development

    No branches or pull requests

    Issue actions