confluentinc/confluent-kafka-python

When consumer is paused check if it's paused

Open

#1.793 geöffnet am 8. Aug. 2024

Auf GitHub ansehen
 (2 Kommentare) (1 Reaktion) (0 zugewiesene Personen)Python (909 Forks)batch import
enhancementgood first issuesize:smallstatus:help-wantedstatus:waiting-for-interest

Repository-Metriken

Stars
 (3.526 Stars)
PR-Merge-Metriken
 (Durchschn. Merge 10T 2h) (27 gemergte PRs in 30 T)

Beschreibung

Description

Feature request. When pausing a consumer, it would be nice if there was a way to check if the consumer is paused. For example a consumer could be paused / resumed based on various conditions and the user may want to know the current state of the consumer. Currently the only way to do this would be to store the state externally in another variable.

How to reproduce

from confluent_kafka import Consumer

c = Consumer({...})
c.subscribe(topics)
c.pause(topic_partitions)
# how to check if the consumer is paused?

Ideally the consumer would have a method like .is_consumer_paused() or a property .paused

Contributor Guide

Research-Richtung
Untersuche die Interna der Consumer Klasse, ob ein pausierter Zustand verfolgt wird. Wenn nicht, füge eine Methode oder Eigenschaft hinzu, um ihn offen zu legen.
Tech Stack
python
Domain
backend
Issue Type
Funktion
SchwierigkeitGeschätzte Implementierungsschwierigkeit für neue Contributors, von 1 für sehr kleine Änderungen bis 5 für Expertenarbeit.
1
Geschätzte ZeitEin grober Zeitrahmen, um zu recherchieren, zu implementieren, zu testen und einen Pull Request vorzubereiten.
Unter 1 Stunde
AktivitätsstatusWie verfügbar das Issue gerade wirkt: frisch, aktiv, stale, blockiert oder wartet auf Maintainer-Input.
Aktiv
KlarheitWie klar das Issue die erwartete Änderung, Akzeptanzkriterien und den nächsten Schritt erklärt.
Klar
Voraussetzungen
PythonKafka
EinsteigerfreundlichkeitEin Score von 1 bis 100, der schätzt, wie zugänglich dieses Issue für First-Time Contributors ist.
85