P

Python client for Apache Kafka

Settings | Report Duplicate

0

I Use This!

Moderate Activity

Commits : Listings

Analyzed about 1 hour ago. based on code collected about 1 hour ago.

Commit Message	Contributor	Files Modified	Lines Added	Lines Removed	Code Location	Date
Aug 10, 2024 — Aug 10, 2025 Showing page 27 of 83 Search / Filter on:
pylint 1.7.0+ supports python 3.6 and merge py36 into common tstenv (#1095)	Jianbin Wei	More...				over 8 years ago
Improve error message when expiring batches in KafkaProducer (#1077)	Dana Powers	More...				over 8 years ago
Warn dont raise on DNS lookup failures (#1091)	Dana Powers	More...				over 8 years ago
Ignore not-context-manager pylint error (#1092)	Dana Powers	More...				over 8 years ago
Deal with brokers that disappear, reappear with different IP address (#1085)	Mike Fischer	More...				over 8 years ago
Follow-up to #1068: remove not-implemented comments	Dana Powers	More...				over 8 years ago
readthedocs.io follow-up to #1074 for docs/	Dana Powers	More...				over 8 years ago
Update RTD links with https / .io (#1074)	Jeff Widman	More...				over 8 years ago
Timeout idle connections via connections_max_idle_ms (#1068)	Dana Powers	More...				over 8 years ago
Avoid multiple connection attempts when refreshing metadata (#1067)	Dana Powers	More...				over 8 years ago
Catch socket.errors when sending / recving bytes on wake socketpair (#1069)	Dana Powers	More...				over 8 years ago
Fix poll() hyperlink in KafkaClient	Jeff Widman	More...				over 8 years ago
Update README: Prefer python-lz4 over lz4tools (#1057)	Kirill Ignatev	More...				over 8 years ago
Fix typo (#1054)	Jeff Widman	More...				over 8 years ago
Bump version for development	Dana Powers	More...				over 8 years ago
Release 1.3.3	Dana Powers	More...				over 8 years ago
Derive all api classes from Request / Response base classes (#1030)	Dana Powers	More...				over 8 years ago
Alter test skips: python-lz4 works on python26, but not pypy	Dana Powers	More...				over 8 years ago
LZ4 support in kafka 0.8/0.9 does not accept a ContentSize header	Dana Powers	More...				over 8 years ago
Update changelog	Dana Powers	More...				over 8 years ago
Avoid re-encoding for message crc check (#1027)	Dana Powers	More...				over 8 years ago
Additional docstrings for autocommit close option	Dana Powers	More...				over 8 years ago
Optionally skip auto-commit during consumer.close (#1031)	Dana Powers	More...				over 8 years ago
Prefer python-lz4 over lz4f if available	Dana Powers	More...				over 8 years ago
Return copy of consumer subscription set (#1029)	Dana Powers	More...				over 8 years ago
Fix kwarg handing in kafka.protocol.struct.Struct (#1025)	Dana Powers	More...				over 8 years ago
Short-circuit group coordinator requests when NodeNotReady (#995)	Dana Powers	More...				over 8 years ago
Avoid unknown coordinator after client poll (#1023)	Dana Powers	More...				over 8 years ago
Free lz4 decompression context to avoid leak	Dana Powers	More...				over 8 years ago
Add optional kwarg to ready and is_ready to disable metadata-priority logic (#1017)	Dana Powers	More...				over 8 years ago

←
1
2
…
23
24
25
26
27
28
29
30
31
…
82
83
→