P

Python client for Apache Kafka

Settings | Report Duplicate

0

I Use This!

Moderate Activity

Commits : Listings

Analyzed 1 day ago. based on code collected 1 day ago.

Commit Message	Contributor	Files Modified	Lines Added	Lines Removed	Code Location	Date
Aug 04, 2024 — Aug 04, 2025 Showing page 26 of 83 Search / Filter on:
conn: Catch ssl.EOFErrors on Python3.3 so we close the failing conn (#1162)	Hannu Valtonen	More...				about 8 years ago
Fix test for older brokers	Taras Voinarovskiy	More...				about 8 years ago
Changed retrieve_offsets to allow fetching multiple offsets at once	Taras Voinarovskiy	More...				about 8 years ago
Merge pull request #1160 from dpkp/issue1155	Taras Voinarovskyi	More...				about 8 years ago
Fix test for older brokers	Taras Voinarovskiy	More...				about 8 years ago
Added basic support for offsets_for_times API. Still needs to group by nodes and send in parallel.	Taras Voinarovskiy	More...				about 8 years ago
Make UnknownTopicOrPartitionError retriable error	Taras Voinarovskiy	More...				about 8 years ago
Fix batch expiry messages to state seconds	Dominic Evans	More...				about 8 years ago
Use for join-time-max and sync-time-max metrics Max() measure function (#1146)	Alexey Pervushin	More...				about 8 years ago
added gssapi support (Kerberos) for SASL (#1152)	Harald	More...				about 8 years ago
Add note, that `max_in_flight_requests_per_connection>1` may change order or messages (#1149)	Taras Voinarovskyi	More...				about 8 years ago
producer: fix produce timeout message (#1151)	Mika Eloranta	More...				about 8 years ago
Protocol updates for 0.11.0.0 (#1127)	Dana Powers	More...				about 8 years ago
change_subscription called only when necessary (#1132)	Petr Šebek	More...				about 8 years ago
Use logging's built-in string interpolation	Jeff Widman	More...				about 8 years ago
Fix typo	Jeff Widman	More...				about 8 years ago
producer: Set exit timeout to 0 for atexit handler to match __del__ (#1126)	Hannu Valtonen	More...				about 8 years ago
KIP-144: Exponential backoff for broker reconnections (#1124)	Dana Powers	More...				about 8 years ago
Backoff on unavailable group coordinator retry (#1125)	Dana Powers	More...				about 8 years ago
Fixup for #1085 -- only check for changed metadata on disconnected nodes	Dana Powers	More...				about 8 years ago
Do not test fetched_size with fetch_max_bytes since 0.11 brokers will return more data than 0.10	Dana Powers	More...				about 8 years ago
Increase max_buffer_size for test_large_messages	Dana Powers	More...				about 8 years ago
Fix fetch_max_bytes=1 consumer integration test	Dana Powers	More...				about 8 years ago
Use fixture hostname (dont assume localhost)	Dana Powers	More...				about 8 years ago
Add 0.11.0.0 server resources (reduced offsets.topic.replication.factor=1)	Dana Powers	More...				about 8 years ago
Follow-up: support manual py26 testing; dont advertise 3.3 support	Dana Powers	More...				about 8 years ago
Add kafka 0.10.2.1 into integration testing version (#1096)	Jianbin Wei	More...				about 8 years ago
Describe consumer thread-safety	Linus Wallgren	More...				about 8 years ago
Update exception docstring	Andrew Kowalik	More...				over 8 years ago
raise KafkaTimeoutException when flush times out	Andrew Kowalik	More...				over 8 years ago

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