Skip to content

Issues: confluentinc/confluent-kafka-python

New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

Sign up for GitHub

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Clear current search query, filters, and sorts
210 Open 924 Closed
210 Open 924 Closed
Author
Filter by author
Loading
Label
Filter by label
Loading
Use alt + click/return to exclude labels
or ⇧ + click/return for logical OR
Projects
Filter by project
Loading
Milestones
Filter by milestone
Loading
Assignee
Filter by who’s assigned
Sort
Sort by
Newest Oldest Most commented Least commented Recently updated Least recently updated Best match
Most reactions
👍 👎 😄 🎉 😕 ❤️ 🚀 👀

Issues list

Describe log dirs partitions size in admin client ?
#1179 opened Aug 6, 2021 by Courouge
3 of 4 tasks
1
How to correctly handle a message.error() for a corrupted message vs retryable error ? enhancement MEDIUM question
#1275 opened Jan 29, 2022 by mkmoisen
2
Use function consume lost message after call seek
#1270 opened Jan 20, 2022 by luoyucumt
6 of 7 tasks
2
Future hangs indefinetly when removed from the dict it is returned with. bug
#1242 opened Nov 25, 2021 by mkstickx
5 of 7 tasks
2
Add AggregateSerializer, AggregateDeserializer enhancement LOW
#1237 opened Nov 16, 2021 by rkoeninger
2
About creating consumers bug
#1232 opened Nov 8, 2021 by cxin-william
7 tasks
7
Best practice to work with django and confluent_kafka consmer/producer question
#1215 opened Oct 5, 2021 by itamar27
1 of 7 tasks
1
Enhancement - use schema registry to validate provided schemas for Protobuf and Json deserialisers schema registry
#1210 opened Oct 2, 2021 by boofhead
7 tasks
How to deal with msg.error() in batch API
#1195 opened Sep 8, 2021 by nikunjy
7 tasks
1
should not use _SchemaCache in SchemaRegistryClient bug schema registry
#1194 opened Sep 6, 2021 by puella2021
1
Message.__len__ fails if the value has been deserialized to a type that does not support __len__
#1192 opened Sep 1, 2021 by choogeboom
@jliunyu
2
Producer hide librdkafka failures and silently return None as message on poll
#1187 opened Aug 12, 2021 by Hubbitus
2
Termination has been stuck
#1185 opened Aug 11, 2021 by ht-jo
6 of 7 tasks
5
Support for connect_cb
#1097 opened Apr 21, 2021 by hallfox
7
Consumer.offsets_for_times() returns the same offset for different timestamps
#1178 opened Aug 6, 2021 by miroslavbel
3 of 7 tasks
4
Faster json library? schema registry
#1177 opened Aug 4, 2021 by sonicxml
Cannot create local docker-compose file for Confluent Cloud env replication wait info
#1176 opened Aug 3, 2021 by nilansaha
7 tasks
3
A support for 'Protobuf Deserializer' with schema registry question schema registry
#1174 opened Aug 1, 2021 by dorocoder
4
Confluent-Kafka-Python producing SSL handshake error question
#1163 opened Jul 14, 2021 by arjun180
7 tasks
4
How can I use protobuf deserializer intergrated with spark streaming? schema registry
#1136 opened Jun 14, 2021 by dino-chiio
AdminClient creating topic nondeterministically fails with "The active controller appears to be node x"
#1132 opened May 28, 2021 by OneRaynyDay
7 tasks done
1
Feature Request: Kerberos support for Schema Registry enhancement schema registry
#1129 opened May 25, 2021 by dusts66
2 of 7 tasks
2
Hard-deleting a subject fails if the subject has already been soft-deleted schema registry
#1127 opened May 24, 2021 by PatrickTu
6 of 7 tasks
6
is there a way to override the producer partitioner?
#1107 opened Apr 28, 2021 by ArshiAAkhavan
1
Python Dictionary to Class Handling (How/Why) question
#1100 opened Apr 21, 2021 by slominskir
5
ProTip! Type g p on any issue or pull request to go back to the pull request listing page.