confluentinc/confluent-kafka-python

Auf GitHub ansehen

Confluent's Kafka Python Client

Sterne: 509
Forks: 964
Offene Anfänger-Issues: 0
Indexierte Issues: 132
Ø Merge: 2 T. 2 Std.
Gemergte PRs (30 T.): 14

Vorherrschende Sprache: Python
Lizenz: Keine Lizenzdaten
Letzter GitHub-Push: 14.9.2026
Zuletzt indexiert: 15.9.2026
Beitragsleitfaden: Kein Beitragsleitfaden
Verhaltenskodex: Kein Verhaltenskodex
Anfänger-Labels: good first issue

Offen Alle

Bisher 132 offene Issues indexiert

Python implementation of Kafka Streams? Offen

enhancement question size:huge status:waiting-for-interest

confluentinc/confluent-kafka-python#38 · 44 Kommentare · 144 Reaktionen · 0 zugewiesene Personen · Indexiert am 15.9.2026
Differentiate between temporary and permanent errors Offen

enhancement priority:high size:small status:planned

confluentinc/confluent-kafka-python#147 · 0 Kommentare · 12 Reaktionen · 0 zugewiesene Personen · Indexiert am 15.9.2026
AvroConsumer — access to key & value schemas Offen

component:schema-registry enhancement priority:high status:help-wanted

confluentinc/confluent-kafka-python#289 · 5 Kommentare · 4 Reaktionen · 0 zugewiesene Personen · Indexiert am 15.9.2026
Request: list of topics, list/number of partitions and watermark offsets for each Offen

api-change component:consumer component:librdkafka enhancement status:planned

confluentinc/confluent-kafka-python#330 · 17 Kommentare · 10 Reaktionen · 0 zugewiesene Personen · Indexiert am 15.9.2026
Consumer.get_watermark_offsets Ignores Timeout Parameter in Some Situations Offen

component:librdkafka investigate further

confluentinc/confluent-kafka-python#413 · 4 Kommentare · 0 Reaktionen · 0 zugewiesene Personen · Indexiert am 15.9.2026
KafkaError error strings are unicode on Windows when language is non-english Offen

bug good first issue investigate further os:windows

confluentinc/confluent-kafka-python#448 · 5 Kommentare · 0 Reaktionen · 0 zugewiesene Personen · Indexiert am 15.9.2026
Segfault if poll() called from delivery_callback Offen

bug enhancement investigate further status:waiting-for-interest

confluentinc/confluent-kafka-python#457 · 4 Kommentare · 1 Reaktion · 0 zugewiesene Personen · Indexiert am 15.9.2026
Automatic reconnection issue Offen

bug status:wontfix

confluentinc/confluent-kafka-python#463 · 6 Kommentare · 0 Reaktionen · 0 zugewiesene Personen · Indexiert am 15.9.2026
read access to consumer/producer configuration Offen

enhancement good first issue status:waiting-for-interest

confluentinc/confluent-kafka-python#465 · 4 Kommentare · 0 Reaktionen · 0 zugewiesene Personen · Indexiert am 15.9.2026
Fix type hinting of avro messages Offen

code:python component:schema-registry good first issue maintenance

confluentinc/confluent-kafka-python#466 · 4 Kommentare · 0 Reaktionen · 0 zugewiesene Personen · Indexiert am 15.9.2026
list_topics() crash Offen

bug investigate further

confluentinc/confluent-kafka-python#471 · 4 Kommentare · 0 Reaktionen · 0 zugewiesene Personen · Indexiert am 15.9.2026
Feature: Pre-built binary support for Alpine Offen

enhancement investigate further status:planned

confluentinc/confluent-kafka-python#520 · 11 Kommentare · 6 Reaktionen · 0 zugewiesene Personen · Indexiert am 15.9.2026
fastavro is no longer used by default Offen

component:schema-registry component:serdes investigate further

confluentinc/confluent-kafka-python#616 · 0 Kommentare · 3 Reaktionen · 0 zugewiesene Personen · Indexiert am 15.9.2026
Unable to import cimpl Offen

component:consumer investigate further priority:high

confluentinc/confluent-kafka-python#641 · 7 Kommentare · 2 Reaktionen · 0 zugewiesene Personen · Indexiert am 15.9.2026
Assertion failed: rd_slice_abs_offset Offen

bug code:C investigate further priority:high

confluentinc/confluent-kafka-python#689 · 24 Kommentare · 0 Reaktionen · 0 zugewiesene Personen · Indexiert am 15.9.2026
how to check connection before producer or consumer start. Offen

enhancement investigate further priority:high question status:planned status:under-review

confluentinc/confluent-kafka-python#705 · 11 Kommentare · 4 Reaktionen · 0 zugewiesene Personen · Indexiert am 15.9.2026
Specifying a Python list for config `bootstrap.servers` fails silently with no errors or indications Offen

code:python enhancement good first issue investigate further size:small status:planned

confluentinc/confluent-kafka-python#711 · 6 Kommentare · 2 Reaktionen · 0 zugewiesene Personen · Indexiert am 15.9.2026
SystemError if assign_cb raises Exception Offen

bug code:C priority:high

confluentinc/confluent-kafka-python#729 · 2 Kommentare · 1 Reaktion · 0 zugewiesene Personen · Indexiert am 15.9.2026
Don't set librdkafka error_cb if a python callback is not provided. Offen

bug code:C component:producer enhancement status:help-wanted status:waiting-for-interest

confluentinc/confluent-kafka-python#745 · 1 Kommentar · 0 Reaktionen · 0 zugewiesene Personen · Indexiert am 15.9.2026
Document Producer.flush default timeout Offen

docs priority:high

confluentinc/confluent-kafka-python#755 · 3 Kommentare · 0 Reaktionen · 0 zugewiesene Personen · Indexiert am 15.9.2026
Deprecate Producer_list_topics Offen

enhancement maintenance status:help-wanted status:waiting-for-interest

confluentinc/confluent-kafka-python#756 · 0 Kommentare · 2 Reaktionen · 0 zugewiesene Personen · Indexiert am 15.9.2026
segfault when trying to construct AvroProducer Offen

bug component:schema-registry investigate further

confluentinc/confluent-kafka-python#769 · 0 Kommentare · 0 Reaktionen · 0 zugewiesene Personen · Indexiert am 15.9.2026
consume(0) cannot trigger stats_cb? Offen

component:librdkafka investigate further

confluentinc/confluent-kafka-python#788 · 1 Kommentar · 0 Reaktionen · 0 zugewiesene Personen · Indexiert am 15.9.2026
Add blocking mode for topic subscription Offen

component:consumer enhancement status:waiting-for-interest

confluentinc/confluent-kafka-python#854 · 6 Kommentare · 1 Reaktion · 0 zugewiesene Personen · Indexiert am 15.9.2026
Ambigous error when consumer is fenced by group.instance.id Offen

bug code:C component:consumer investigate further status:blocked

confluentinc/confluent-kafka-python#869 · 5 Kommentare · 0 Reaktionen · 0 zugewiesene Personen · Indexiert am 15.9.2026
AvroDeserializer reader schema cannot ignore values required in writer schema Offen

component:schema-registry component:serdes good first issue

confluentinc/confluent-kafka-python#887 · 1 Kommentar · 4 Reaktionen · 0 zugewiesene Personen · Indexiert am 15.9.2026
Question: Backward compatible schemas and old messages Offen

component:schema-registry investigate further

confluentinc/confluent-kafka-python#892 · 2 Kommentare · 1 Reaktion · 0 zugewiesene Personen · Indexiert am 15.9.2026
Update README.md to reflect the legacy status of AvroProducer and AvroConsumer Offen

component:schema-registry docs good first issue priority:high

confluentinc/confluent-kafka-python#910 · 4 Kommentare · 11 Reaktionen · 0 zugewiesene Personen · Indexiert am 15.9.2026
After Decoding mesaage, consumer should return schema ID Offen

component:schema-registry enhancement

confluentinc/confluent-kafka-python#958 · 2 Kommentare · 0 Reaktionen · 0 zugewiesene Personen · Indexiert am 15.9.2026
Producer goes to retry-backoff by send_offsets_to_transaction() thus degrading performance Offen

component:librdkafka component:producer investigate further

confluentinc/confluent-kafka-python#967 · 6 Kommentare · 0 Reaktionen · 0 zugewiesene Personen · Indexiert am 15.9.2026
Certificate Param in Config Offen

component:librdkafka component:schema-registry enhancement status:waiting-for-interest workaround

confluentinc/confluent-kafka-python#977 · 2 Kommentare · 4 Reaktionen · 0 zugewiesene Personen · Indexiert am 15.9.2026
Admin client raises _TIMED_OUT error rather than SASL authentication error when topic creation fails Offen

bug component:admin

confluentinc/confluent-kafka-python#1034 · 0 Kommentare · 10 Reaktionen · 0 zugewiesene Personen · Indexiert am 15.9.2026
Support for connect_cb Offen

code:C enhancement investigate further status:waiting-for-interest

confluentinc/confluent-kafka-python#1097 · 8 Kommentare · 0 Reaktionen · 0 zugewiesene Personen · Indexiert am 15.9.2026
is there a way to override the producer partitioner? Offen

component:producer enhancement status:waiting-for-interest

confluentinc/confluent-kafka-python#1107 · 1 Kommentar · 1 Reaktion · 0 zugewiesene Personen · Indexiert am 15.9.2026
Feature Request: Kerberos support for Schema Registry Offen

component:schema-registry enhancement

confluentinc/confluent-kafka-python#1129 · 2 Kommentare · 0 Reaktionen · 0 zugewiesene Personen · Indexiert am 15.9.2026
A support for 'Protobuf Deserializer' with schema registry Offen

component:schema-registry question

confluentinc/confluent-kafka-python#1174 · 8 Kommentare · 6 Reaktionen · 0 zugewiesene Personen · Indexiert am 15.9.2026
Describe log dirs partitions size in admin client ? Offen

component:admin enhancement status:planned

confluentinc/confluent-kafka-python#1179 · 1 Kommentar · 7 Reaktionen · 0 zugewiesene Personen · Indexiert am 15.9.2026
Producer hide librdkafka failures and silently return None as message on poll Offen

bug code:python priority:high

confluentinc/confluent-kafka-python#1187 · 2 Kommentare · 0 Reaktionen · 0 zugewiesene Personen · Indexiert am 15.9.2026
Message.__len__ fails if the value has been deserialized to a type that does not support __len__ Offen

bug code:C size:small status:help-wanted

confluentinc/confluent-kafka-python#1192 · 2 Kommentare · 0 Reaktionen · 1 zugewiesene Person · Indexiert am 15.9.2026
Enhancement - use schema registry to validate provided schemas for Protobuf and Json deserialisers Offen

component:schema-registry enhancement

confluentinc/confluent-kafka-python#1210 · 0 Kommentare · 0 Reaktionen · 0 zugewiesene Personen · Indexiert am 15.9.2026
About creating consumers Offen

bug code:python size:small status:help-wanted

confluentinc/confluent-kafka-python#1232 · 8 Kommentare · 0 Reaktionen · 0 zugewiesene Personen · Indexiert am 15.9.2026
Add AggregateSerializer, AggregateDeserializer Offen

enhancement priority:low status:help-wanted status:waiting-for-interest

confluentinc/confluent-kafka-python#1237 · 2 Kommentare · 0 Reaktionen · 0 zugewiesene Personen · Indexiert am 15.9.2026
How to correctly handle a message.error() for a corrupted message vs retryable error ? Offen

docs question

confluentinc/confluent-kafka-python#1275 · 2 Kommentare · 0 Reaktionen · 0 zugewiesene Personen · Indexiert am 15.9.2026
"Handle is terminating" exception when calling `delete_topics` Offen

bug enhancement status:waiting-for-interest

confluentinc/confluent-kafka-python#1298 · 3 Kommentare · 0 Reaktionen · 0 zugewiesene Personen · Indexiert am 15.9.2026
Consumer.consume commits offsets when 'enable.auto.commit': False Offen

question

confluentinc/confluent-kafka-python#1299 · 11 Kommentare · 1 Reaktion · 0 zugewiesene Personen · Indexiert am 15.9.2026
Unit Tests don't clean up docker containers Offen

bug investigate further maintenance priority:high

confluentinc/confluent-kafka-python#1311 · 2 Kommentare · 0 Reaktionen · 0 zugewiesene Personen · Indexiert am 15.9.2026
Implement `timeout` option for `seek` Offen

enhancement priority:low status:waiting-for-interest

confluentinc/confluent-kafka-python#1323 · 2 Kommentare · 0 Reaktionen · 0 zugewiesene Personen · Indexiert am 15.9.2026
Producer logging thousands of errors in a very short timespan (Broker transport failure) Offen

bug component:librdkafka investigate further priority:low

confluentinc/confluent-kafka-python#1328 · 8 Kommentare · 0 Reaktionen · 0 zugewiesene Personen · Indexiert am 15.9.2026
VALUE_DESERIALIZATION - Connection reset by peer Offen

enhancement priority:low status:help-wanted status:waiting-for-interest workaround

confluentinc/confluent-kafka-python#1334 · 2 Kommentare · 0 Reaktionen · 0 zugewiesene Personen · Indexiert am 15.9.2026
automated style checking Offen

enhancement maintenance status:waiting-for-interest

confluentinc/confluent-kafka-python#1351 · 2 Kommentare · 0 Reaktionen · 0 zugewiesene Personen · Indexiert am 15.9.2026

confluentinc/confluent-kafka-python

Neue Issues direkt in Ihr Postfach