1 Pull request merged by 1 person

• DGS-21268 Add support for full payload encryption

  #2011 merged Jul 18, 2025

1 Pull request opened by 1 person

• [KIP-848] Added online upgrade and downgrade test

  #2012 opened Jul 17, 2025

21 Issues closed by 1 person

• Inaccurate documentation for `SerializationContext` `field` parameter regarding `MessageField` usage

  #1657 closed Jul 18, 2025

• Sometimes data cannot be consumed (disappears after restarting)

  #1653 closed Jul 18, 2025

• Not all messages are produced to a Kafka topic

  #1644 closed Jul 18, 2025

• How to set delivery.reports to false ?

  #1637 closed Jul 18, 2025

• AttributeError: 'NoneType' object has no attribute value

  #1632 closed Jul 18, 2025

• Trying to connect to MSK With SASL_SSL

  #1588 closed Jul 17, 2025

• Unable to install confluent-kafka library from source in docker container

  #1567 closed Jul 17, 2025

• "module 'os' has no attribute 'add_dll_directory'"

  #1530 closed Jul 17, 2025

• AttributeError: module 'os' has no attribute 'add_dll_directory' - Python 3.9 - Lambda Function in AWS

  #1528 closed Jul 17, 2025

• Segfault of binary wheel on Red Hat Enterprise 8 Python 3.6/3.8

  #1519 closed Jul 17, 2025

• Recommended way to partial historical data?

  #1509 closed Jul 17, 2025

• Kafka client keeps disconnecting after moving to SSL

  #1494 closed Jul 17, 2025

• oauth token not refreshing

  #1485 closed Jul 17, 2025

• Error, when installing requirements in docker-compose. Macbook M2

  #1482 closed Jul 17, 2025

• Unable to connect to confluent cloud

  #1479 closed Jul 17, 2025

• AttributeError: module 'os' has no attribute 'add_dll_directory' - Python 3.8 - Function Azure

  #1462 closed Jul 17, 2025

• how to know if kafka is down or up

  #1459 closed Jul 17, 2025

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

  #1453 closed Jul 17, 2025

• SerializingProducer is much slower than Producer in Python

  #1440 closed Jul 17, 2025

• Consumer looses partitons after restart connection

  #1305 closed Jul 17, 2025

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

  #1303 closed Jul 17, 2025

1 Issue opened by 1 person

• documentation on Schema, register schema and details on the SchemaRegistryClient are missing

  #2013 opened Jul 18, 2025

35 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.

• Type hint missing for "from confluent_kafka import Message"

  #1310 commented on Jul 17, 2025 • 0 new comments

• Unit Tests don't clean up docker containers

  #1311 commented on Jul 17, 2025 • 0 new comments

• Differentiate Schema Registry Communication Failure From SerializerError

  #1325 commented on Jul 17, 2025 • 0 new comments

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

  #1328 commented on Jul 17, 2025 • 0 new comments

• VALUE_DESERIALIZATION - Connection reset by peer

  #1334 commented on Jul 17, 2025 • 0 new comments

• automated style checking

  #1351 commented on Jul 17, 2025 • 0 new comments

• PEP517

  #1357 commented on Jul 17, 2025 • 0 new comments

• suspicious memory leak in producer (rdkafka)

  #1361 commented on Jul 17, 2025 • 0 new comments

• Updating manylinux version?

  #1377 commented on Jul 17, 2025 • 0 new comments

• How to check for SASL Authentication Errors?

  #1398 commented on Jul 17, 2025 • 0 new comments

• Add typing support

  #1408 commented on Jul 17, 2025 • 0 new comments

• Continuous fuzzing by way of OSS-Fuzz

  #1415 commented on Jul 17, 2025 • 0 new comments

• Number of file handles does not scale with number of Consumer(s)

  #1417 commented on Jul 17, 2025 • 0 new comments

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

  #1423 commented on Jul 17, 2025 • 0 new comments

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

  #1429 commented on Jul 17, 2025 • 0 new comments

• Custom Protobuf Options / Schema Registry Support

  #1470 commented on Jul 17, 2025 • 0 new comments

• Producer. Connection or connection error handling

  #1472 commented on Jul 17, 2025 • 0 new comments

• Consumer not consuming from all assigned partitions

  #1477 commented on Jul 17, 2025 • 0 new comments

• Strange output to the console

  #1478 commented on Jul 17, 2025 • 0 new comments

• Don't understand ssl.ca.pem format

  #1500 commented on Jul 17, 2025 • 0 new comments

• pip install --no-binary :all: confluent-kafka Deprecation Warning

  #1507 commented on Jul 17, 2025 • 0 new comments

• feature request: make Message type user-instantiable

  #1535 commented on Jul 17, 2025 • 0 new comments

• on_revoke callback passed partition list with partition not already in assignment after consumer group session timeout

  #1551 commented on Jul 17, 2025 • 0 new comments

• Question: Do not understand DeserializingConsumer error behaviour. How to construct a robust consumer?

  #1572 commented on Jul 17, 2025 • 0 new comments

• Feature request: cimpl.Message.set_error

  #1585 commented on Jul 17, 2025 • 0 new comments

• Create user for setting ACL rule over topic

  #1589 commented on Jul 17, 2025 • 0 new comments

• Crash (SEGV) in Producer class

  #1590 commented on Jul 17, 2025 • 0 new comments

• Failed to load OpenSSL provider "legacy": error:07880025:common libcrypto routines::reason(524325)

  #1596 commented on Jul 18, 2025 • 0 new comments

• Broker certificate could not be verified.

  #1610 commented on Jul 18, 2025 • 0 new comments

• manual checkpoint

  #1617 commented on Jul 18, 2025 • 0 new comments

• `enable.ssl.certificate.verification` must be a string and not a boolean

  #1633 commented on Jul 18, 2025 • 0 new comments

• Docs should be updated to include the extended return value for the oauth_cb callback

  #1634 commented on Jul 18, 2025 • 0 new comments

• confluent_kafka/cimpl.cpython-36m-x86_64-linux-gnu.so: undefined symbol: rd_kafka_event_AlterConsumerGroupOffsets_result

  #1639 commented on Jul 18, 2025 • 0 new comments

• Consumer commit() None parameters

  #1642 commented on Jul 18, 2025 • 0 new comments

• consumer hangs on consumer.close()

  #1667 commented on Jul 18, 2025 • 0 new comments