Issues

• AvroSerializer, AvroDeserializer, JSONSerializer and ProtobufSerializer resolve to Any under mypy because of __init__ = __init_impl

  component:schema-registry
  confluentinc/confluent-kafka-python#2390 · Filter by author Danthewaann opened on Oct 14, 2026

• After a fatal error, produce() raises KafkaError(_FATAL) with fatal() False

  confluentinc/confluent-kafka-python#2387 · Filter by author kbr- opened on Oct 8, 2026

• Delivery callbacks run with the fatal error still set, so flush() raises SystemError

  confluentinc/confluent-kafka-python#2386 · Filter by author kbr- opened on Oct 8, 2026
  1

• Consumer.commit() docstring says to check .err, but TopicPartition only has .error

  docs
  confluentinc/confluent-kafka-python#2381 · Filter by author HardMax71 opened on Oct 6, 2026

• Support delete_consumer_group_offsets

  confluentinc/confluent-kafka-python#2377 · Filter by author avlonder opened on Oct 3, 2026

• Offset out of range error is not captured

  confluentinc/confluent-kafka-python#2375 · Filter by author wernerdaehn opened on Sep 30, 2026

• TopicPartition class does not have a proper __str__ or __repr__ method

  confluentinc/confluent-kafka-python#2374 · Filter by author wernerdaehn opened on Sep 30, 2026

• Python 3.15 Drops Oct 2nd, Please Build Binary Wheels

  confluentinc/confluent-kafka-python#2373 · Filter by author mkmoisen opened on Sep 29, 2026
  1

• AvroSerializer: use.schema.id does not work with an existing Schema returned by get_schema()

  component:schema-registry
  confluentinc/confluent-kafka-python#2362 · Filter by author IgorShcherbakov opened on Sep 20, 2026
  4

• Upgrade bundled libcurl to 8.21.0 in librdkafka/confluent-kafka artifacts

  securitystatus:planned
  confluentinc/confluent-kafka-python#2343 · Filter by author eshita19 opened on Sep 1, 2026
  1

  

• produce_batch(): support headers and timestamps (headers are currently dropped silently)

  status:waiting-for-interest
  confluentinc/confluent-kafka-python#2320 · Filter by author Lancetnik opened on Aug 4, 2026
  

• Python 3.15 support including binary wheels

  status:planned
  confluentinc/confluent-kafka-python#2299 · Filter by author ericbuehl opened on Jun 29, 2026
  3

• confluent-kafka 2.14.2 / librdkafka 2.14.2 appears to pull vulnerable OpenSSL 3.5.6

  status:planned
  confluentinc/confluent-kafka-python#2282 · Filter by author eshita19 opened on Jun 17, 2026
  2

• AIOProducer.produce execution order and flush() best practices for batching

  confluentinc/confluent-kafka-python#2276 · Filter by author bar1kk opened on Jun 13, 2026
  1

• Wrong type annotations for read only mapping types.

  status:under-review
  confluentinc/confluent-kafka-python#2244 · Filter by author RasmusNygren opened on May 6, 2026

• Wrong signature for KafkaError's 1st parameter in .pyi

  confluentinc/confluent-kafka-python#2243 · Filter by author howamith opened on Apr 30, 2026

• Use joserfc instead of authlib.jose

  confluentinc/confluent-kafka-python#2242 · Filter by author ThermodynamicBeta opened on Apr 29, 2026
  2

• Producer.poll(timeout) blocks for full timeout after delivery callback fires (regression in 2.13.0)

  component:producer
  confluentinc/confluent-kafka-python#2215 · Filter by author launay12u opened on Mar 12, 2026
  1

• [Bug/Question] AsyncIO Module (confluent_kafka.aio): AIOConsumer.poll() and AIOProducer Event Loop Deadlock in ASGI Frameworks (FastAPI/uvicorn)

  component:consumercomponent:producerstatus:planned
  confluentinc/confluent-kafka-python#2211 · Filter by author AlexCai26 opened on Mar 9, 2026
  3

• v2.13.0 - Consumer '.consume()' method does not respect the 'num_messages' and 'timeout' parameters

  status:planned
  confluentinc/confluent-kafka-python#2205 · Filter by author andriy-buryy opened on Feb 26, 2026
  5

• oauth_cb resulting in Core Dump - Fatal Python error: PyGILState_Release: auto-releasing thread-state, but no thread-state for this thread

  confluentinc/confluent-kafka-python#2191 · Filter by author mkmoisen opened on Feb 18, 2026
  2

• Frequent Broker Disconnects Caused by "non-nullable field metrics was serialized as null" with Telemetry Subscriptions

  confluentinc/confluent-kafka-python#2185 · Filter by author shivam-aggarwal-232 opened on Feb 6, 2026
  2

• Race condition when doing .assign(INVALID_OFFSET) followed by .assign(explicit_offset)

  confluentinc/confluent-kafka-python#2184 · Filter by author solutionseekeras opened on Feb 3, 2026
  1

• AvroSerializer with record_subject_name_strategy raises TypeError: SerializationContext cannot be None since 2.13

  component:schema-registry
  confluentinc/confluent-kafka-python#2183 · Filter by author l1nd3r0th opened on Feb 3, 2026
  1

• Version 2.13.0 blocks in SerializingProducer constructor

  status:needs-more-info
  confluentinc/confluent-kafka-python#2164 · Filter by author IgorMilavec opened on Jan 6, 2026
  5