Skip to content

/ kafka-python Public

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

186 Open 1,160 Closed
186 Open 1,160 Closed
Author
Filter by author
Label
Filter by label
Use alt + click/return to exclude labels
or ⇧ + click/return for logical OR
Projects
Filter by project
Milestones
Filter by milestone
Assignee
Filter by who’s assigned
Sort
Sort by
Newest Oldest Most commented Least commented Recently updated Least recently updated
Most reactions
👍 👎 😄 🎉 😕 ❤️ 🚀 👀
SSL certificate passwords
#2268 opened Oct 6, 2021 by SDBrett
Setting connections_max_idle_ms to zero causes error
#2267 opened Sep 29, 2021 by curtis-trynow-io
set parameter sasl.jaas.config for SASL PLAIN
#2265 opened Sep 27, 2021 by mrshanth
HeartbeatThread try cache bug
#2264 opened Sep 27, 2021 by sk-xinye
1
Is it possible to override zookeeper in KafkaAdminClient?
#2262 opened Sep 23, 2021 by romiusprime
Add messages to DB after consuming.
#2261 opened Sep 22, 2021 by awaisZtabs
ssl.PROTOCOL_SSLv23 has been deprecated since python 3.6
#2259 opened Aug 27, 2021 by EdwardBlair
BUG: KafkaProducer leaves garbage
#2258 opened Aug 25, 2021 by Gw1p
Kafka Consumer in Python Multiprocessing
#2257 opened Aug 23, 2021 by mrjolollo
KafkaConsumer - get the latest N messages
#2254 opened Aug 9, 2021 by joseboretto
[kafka.conn] ERROR DNS lookup failed for sea-crawl002:9092 (AddressFamily.AF_UNSPEC)
#2253 opened Aug 6, 2021 by hongjhhh
1
socket.inet_pton() passed invalid parameters in conn.py
#2251 opened Jul 29, 2021 by kevinlombardo
How to create topics using kafka-python
#2250 opened Jul 28, 2021 by georgethomas08
1
Infinite loop on non existing DNS
#2249 opened Jul 21, 2021 by norraxx
Missing support for OffsetDelete API (47)
#2247 opened Jul 5, 2021 by RyanSept
KafkaClient‘s cluster._brokers maybe empty but _connecting has node
#2246 opened Jul 1, 2021 by ohye3166
This library should have type annotations
#2245 opened Jun 29, 2021 by benbariteau
Why does producer asks for describing every topic in cluster?
#2244 opened Jun 28, 2021 by Pyrrha
4
Can we have kakfa headers value as string instead of bytes?
#2242 opened Jun 24, 2021 by tara-9
poll never stops with incorrect password for SCRAM-SHA-256
#2238 opened Jun 2, 2021 by AleksandrIakhnev
kerberos auth parameter to pass ticket cache?
#2236 opened May 26, 2021 by zenoran
How to use the transaction function of python-kafka
#2235 opened May 23, 2021 by junzisheng
Iterator results in "Heartbeat poll expired, leaving group" if topic is idle for several hours
#2234 opened May 20, 2021 by cainbit
Integration with Confluent?
#2233 opened May 17, 2021 by jacopofar
Would you consider support for MSK & IAM integration ?
#2232 opened May 13, 2021 by andormarkus
ProTip! Mix and match filters to narrow down what you’re looking for.