1 Pull request merged by 1 person

• Add JSON Schema validation test; fix typo

  #2003 merged Jul 1, 2025

3 Pull requests opened by 1 person

• Fixed non-tool path prefix file names for python conventions

  #2000 opened Jun 24, 2025

• Manifest tweak

  #2001 opened Jun 25, 2025

• Some of our tooling lands temporary files into the directory

  #2002 opened Jun 26, 2025

21 Issues closed by 4 people

• stats_cb values for Topic->Partitions is always 0, or -1 or -1001. Trying to get consumer_lag

  #794 closed Jun 26, 2025

• Question. Is there any documetation on AdminClient describe_configs?

  #792 closed Jun 26, 2025

• BufferError: Local: Queue Full

  #781 closed Jun 26, 2025

• Facing "Timed out ProduceRequest in flight" messages

  #771 closed Jun 26, 2025

• Docs Improvement: enable.auto.commit

  #770 closed Jun 26, 2025

• Automate wheelhouse contents verification in test-manylinux.sh

  #761 closed Jun 26, 2025

• please remove installation of LICENSE as datafile

  #714 closed Jun 25, 2025

• Issue Installing from Source

  #660 closed Jun 25, 2025

• unable to perform conda install python-confluent-kafka

  #635 closed Jun 25, 2025

• Python 3.6+ support?

  #620 closed Jun 25, 2025

• assignment() returns empty list

  #615 closed Jun 25, 2025

• Gevent compatibility?

  #612 closed Jun 25, 2025

• README for tests and missing 'pytest-timeout'

  #658 closed Jun 25, 2025

• Error in the execution of a confluent-kafka-python producer on spark for Kafka

  #485 closed Jun 25, 2025

• Delivery failed after 5 min timeout for certain value sizes

  #476 closed Jun 25, 2025

• Feature request: Schema with Message in AvroConsumer

  #449 closed Jun 24, 2025

• consume(timeout=1) takes 5 seconds

  #407 closed Jun 24, 2025

• Conda packages are available on conda-forge

  #253 closed Jun 24, 2025

• No such file or directory: 'ValueSchema.avsc'

  #186 closed Jun 24, 2025

• Confluent-kafka-python, Tornado and GIL

  #100 closed Jun 24, 2025

• Consumer unable to read current offset position until one message is consumed for each partition assigned

  #406 closed Jun 24, 2025

56 Unresolved conversations

Sometimes conversations happen on old items that aren’t yet closed. Here is a list of all the Issues and Pull Requests with unresolved conversations.

• Continuous fuzzing by way of OSS-Fuzz

  #1415 commented on Jun 24, 2025 • 0 new comments

• Type hint missing for "from confluent_kafka import Message"

  #1310 commented on Jun 24, 2025 • 0 new comments

• No module named 'confluent_kafka.cimpl' - Python 3.7 and confluent-kafka - functions Azure

  #1453 commented on Jun 24, 2025 • 0 new comments

• SerializingProducer is much slower than Producer in Python

  #1440 commented on Jun 24, 2025 • 0 new comments

• Add `SchemaRegistryClient` methods for all schema/subject REST endpoints

  #1429 commented on Jun 24, 2025 • 0 new comments

• Allow strict validation with `fastavro`, to fail when extra fields are present in the records

  #1423 commented on Jun 24, 2025 • 0 new comments

• Cooperative rebalancing example

  #1420 commented on Jun 24, 2025 • 0 new comments

• ProtobufDeserializer raises ValueError("MessageDescriptor not found in file") with a message type generated by the protocol buffer compiler

  #1390 commented on Jun 24, 2025 • 0 new comments

• Updating manylinux version?

  #1377 commented on Jun 24, 2025 • 0 new comments

• automated style checking

  #1351 commented on Jun 24, 2025 • 0 new comments

• Producer logging thousands of errors in a very short timespan (Broker transport failure)

  #1328 commented on Jun 24, 2025 • 0 new comments

• Differentiate Schema Registry Communication Failure From SerializerError

  #1325 commented on Jun 24, 2025 • 0 new comments

• Unit Tests don't clean up docker containers

  #1311 commented on Jun 24, 2025 • 0 new comments

• Schema registry API response don't match docs for schemas with references

  #1303 commented on Jun 24, 2025 • 0 new comments

• No module named 'confluent_kafka.cimpl' AWS Lambda / Python 3.9

  #1295 commented on Jun 24, 2025 • 0 new comments

• How to correctly handle a message.error() for a corrupted message vs retryable error ?

  #1275 commented on Jun 24, 2025 • 0 new comments

• Support Python context managers/with statement

  #1244 commented on Jun 24, 2025 • 0 new comments

• Python implementation of Kafka Streams?

  #38 commented on Jun 24, 2025 • 0 new comments

• Differentiate between temporary and permanent errors

  #147 commented on Jun 24, 2025 • 0 new comments

• Ctrl + C can not terminate the program

  #209 commented on Jun 24, 2025 • 0 new comments

• AvroConsumer — access to key & value schemas

  #289 commented on Jun 24, 2025 • 0 new comments

• Request: list of topics, list/number of partitions and watermark offsets for each

  #330 commented on Jun 24, 2025 • 0 new comments

• Consumer.get_watermark_offsets Ignores Timeout Parameter in Some Situations

  #413 commented on Jun 24, 2025 • 0 new comments

• KafkaError error strings are unicode on Windows when language is non-english

  #448 commented on Jun 24, 2025 • 0 new comments

• Segfault if poll() called from delivery_callback

  #457 commented on Jun 25, 2025 • 0 new comments

• Automatic reconnection issue

  #463 commented on Jun 25, 2025 • 0 new comments

• read access to consumer/producer configuration

  #465 commented on Jun 25, 2025 • 0 new comments

• Fix type hinting of avro messages

  #466 commented on Jun 25, 2025 • 0 new comments

• list_topics() crash

  #471 commented on Jun 25, 2025 • 0 new comments

• Support for multiple schemas in one topic

  #477 commented on Jun 25, 2025 • 0 new comments

• Feature: Pre-built binary support for Alpine

  #520 commented on Jun 25, 2025 • 0 new comments

• get_latest_schema() doesn't raise for log error for all the codes. It makes it difficult to debug

  #584 commented on Jun 25, 2025 • 0 new comments

• fastavro is no longer used by default

  #616 commented on Jun 25, 2025 • 0 new comments

• Unable to import cimpl

  #641 commented on Jun 25, 2025 • 0 new comments

• Assertion failed: rd_slice_abs_offset

  #689 commented on Jun 25, 2025 • 0 new comments

• how to check connection before producer or consumer start.

  #705 commented on Jun 25, 2025 • 0 new comments

• Specifying a Python list for config `bootstrap.servers` fails silently with no errors or indications

  #711 commented on Jun 25, 2025 • 0 new comments

• SystemError if assign_cb raises Exception

  #729 commented on Jun 26, 2025 • 0 new comments

• Don't set librdkafka error_cb if a python callback is not provided.

  #745 commented on Jun 26, 2025 • 0 new comments

• Document Producer.flush default timeout

  #755 commented on Jun 26, 2025 • 0 new comments

• Deprecate Producer_list_topics

  #756 commented on Jun 26, 2025 • 0 new comments

• segfault when trying to construct AvroProducer

  #769 commented on Jun 26, 2025 • 0 new comments

• consume(0) cannot trigger stats_cb?

  #788 commented on Jun 26, 2025 • 0 new comments

• Wakeable poll

  #807 commented on Jun 26, 2025 • 0 new comments

• AdminClient.create_topics call hanging

  #833 commented on Jun 30, 2025 • 0 new comments

• How to do custom partition while sending data

  #847 commented on Jun 30, 2025 • 0 new comments

• Add blocking mode for topic subscription

  #854 commented on Jun 30, 2025 • 0 new comments

• SystemError when a callback raises

  #865 commented on Jun 30, 2025 • 0 new comments

• Ambigous error when consumer is fenced by group.instance.id

  #869 commented on Jun 30, 2025 • 0 new comments

• AvroDeserializer reader schema cannot ignore values required in writer schema

  #887 commented on Jun 30, 2025 • 0 new comments

• After Decoding mesaage, consumer should return schema ID

  #958 commented on Jun 30, 2025 • 0 new comments

• Remove python2 specific code

  #1578 commented on Jun 30, 2025 • 0 new comments

• [KIP-848 EA][Tests] Admin API for listing consumer groups now has an optional filter to return only groups of given types

  #1831 commented on Jun 30, 2025 • 0 new comments

• Run soak tests from EC2

  #1908 commented on Jun 30, 2025 • 0 new comments

• [KIP-848] Tests for changes in DescribeConsumerGroups

  #1984 commented on Jun 30, 2025 • 0 new comments

• WARNING: MAJOR (BREAKING) CHANGE: Update dependency urllib3 to v2 [SECURITY] (master)

  #1998 commented on Jul 1, 2025 • 0 new comments