1 Pull request merged by 1 person

• Add MSeal to code owners

  #2009 merged Jul 10, 2025

1 Pull request opened by 1 person

• DGS-21268 Add support for full payload encryption

  #2011 opened Jul 14, 2025

17 Issues closed by 2 people

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

  #1295 closed Jul 15, 2025

• Use function consume lost message after call seek

  #1270 closed Jul 14, 2025

• Best practice to work with django and confluent_kafka consmer/producer

  #1215 closed Jul 14, 2025

• How to deal with msg.error() in batch API

  #1195 closed Jul 14, 2025

• Consumer.offsets_for_times() returns the same offset for different timestamps

  #1178 closed Jul 14, 2025

• Cannot create local docker-compose file for Confluent Cloud env replication

  #1176 closed Jul 14, 2025

• How can I use protobuf deserializer intergrated with spark streaming?

  #1136 closed Jul 14, 2025

• AdminClient creating topic nondeterministically fails with "The active controller appears to be node x"

  #1132 closed Jul 14, 2025

• Python Dictionary to Class Handling (How/Why)

  #1100 closed Jul 14, 2025

• Question: Slowness in the consumer polling config Info -> One Producer-One Topic-One Partition-One Consumer

  #1077 closed Jul 14, 2025

• Consumer performance problems in 1.6.0

  #1054 closed Jul 14, 2025

• Erroneous Connection does not fail

  #1048 closed Jul 14, 2025

• Very first message in a topic is skipped by the consumer

  #1046 closed Jul 14, 2025

• For new group I can't get the consumer to instantiate the group

  #1038 closed Jul 14, 2025

• depends on not widely available librdkafka version

  #1032 closed Jul 14, 2025

• Python client doesn't support hyphens in schema namespace

  #936 closed Jul 14, 2025

• Bug in protobuf serializer: unnecessary roundtrip to schema registry

  #935 closed Jul 14, 2025

1 Issue opened by 1 person

• On new version of httpx SSL throws an error

  #2010 opened Jul 11, 2025

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

• Update README.md to reflect the legacy status of AvroProducer and AvroConsumer

  #910 commented on Jul 14, 2025 • 0 new comments

• multiprocessing Python Kafka consumer client not getting back messages

  #925 commented on Jul 14, 2025 • 0 new comments

• Producer goes to retry-backoff by send_offsets_to_transaction() thus degrading performance

  #967 commented on Jul 14, 2025 • 0 new comments

• Consumer compatible with asyncio

  #1017 commented on Jul 14, 2025 • 0 new comments

• Certificate Param in Config

  #977 commented on Jul 14, 2025 • 0 new comments

• Admin client raises _TIMED_OUT error rather than SASL authentication error when topic creation fails

  #1034 commented on Jul 14, 2025 • 0 new comments

• Support for connect_cb

  #1097 commented on Jul 14, 2025 • 0 new comments

• is there a way to override the producer partitioner?

  #1107 commented on Jul 14, 2025 • 0 new comments

• Faster json library?

  #1177 commented on Jul 14, 2025 • 0 new comments

• Describe log dirs partitions size in admin client ?

  #1179 commented on Jul 14, 2025 • 0 new comments

• Termination has been stuck

  #1185 commented on Jul 14, 2025 • 0 new comments

• Producer hide librdkafka failures and silently return None as message on poll

  #1187 commented on Jul 14, 2025 • 0 new comments

• Message.__len__ fails if the value has been deserialized to a type that does not support __len__

  #1192 commented on Jul 14, 2025 • 0 new comments

• Enhancement - use schema registry to validate provided schemas for Protobuf and Json deserialisers

  #1210 commented on Jul 14, 2025 • 0 new comments

• About creating consumers

  #1232 commented on Jul 14, 2025 • 0 new comments

• Add AggregateSerializer, AggregateDeserializer

  #1237 commented on Jul 14, 2025 • 0 new comments

• Future hangs indefinetly when removed from the dict it is returned with.

  #1242 commented on Jul 14, 2025 • 0 new comments

• Support Python context managers/with statement

  #1244 commented on Jul 14, 2025 • 0 new comments

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

  #1275 commented on Jul 15, 2025 • 0 new comments

• "Handle is terminating" exception when calling `delete_topics`

  #1298 commented on Jul 15, 2025 • 0 new comments

• confluent-kafka-python vs aiokafka for Asynchronous applications

  #1723 commented on Jul 16, 2025 • 0 new comments