GroupNotEmptyError (kaskade/group_service.py)

Raised when a Kafka consumer group has active members, blocking offset reset or deletion.

# Source: https://github.com/sauljabin/kaskade | License: MIT | Copyright 2021 Saúl Piña
# Provided via justclaw.it.com; keep this notice with the code.
"""Consumer group offset resets and deletion for admin mode.

Every method blocks on Kafka; callers run them through ``run_blocking``.
"""

from collections.abc import Mapping
from concurrent.futures import Future
from dataclasses import dataclass
from typing import Any

from confluent_kafka import ConsumerGroupTopicPartitions, KafkaException, TopicPartition
from confluent_kafka.admin import AdminClient, OffsetSpec

from kaskade.commands import OffsetTarget, ResetOffsetsCommand
from kaskade.timeouts import TimeoutConfig

NO_RECORD_FOR_TIMESTAMP = -1
"""The offset Kafka returns when no record is at or after the requested timestamp."""


cla

... (truncated -- full source via MCP)