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 10, 2024 — Aug 10, 2025 Showing page 67 of 83 Search / Filter on:
Support setting offsets in set_topic_partitions(); reorganize offsets initialization	Dana Powers	More...				almost 11 years ago
_client is private var	Dana Powers	More...				almost 11 years ago
Move kafka._msg_iter initialization from __init__() to next()	Dana Powers	More...				almost 11 years ago
self._topics is private; fixup topic iterations for new TopicAndPartition list; add more type checks to set_topic_and_partitions	Dana Powers	More...				almost 11 years ago
Add set_topic_partitions method to configure topics/partitions to consume	Dana Powers	More...				almost 11 years ago
Use client.get_partition_ids_for_topic	Dana Powers	More...				almost 11 years ago
Use configure() to check and set configuration keys	Dana Powers	More...				almost 11 years ago
add private methods _set_consumer_timeout_start() and _check_consumer_timeout()	Dana Powers	More...				almost 11 years ago
Handle FailedPayloadsError on client.send_fetch_request; permit offsets(); update docstring	Dana Powers	More...				almost 11 years ago
Merge pull request #233 from dpkp/str_join_speedup	Mark Roberts	More...				almost 11 years ago
A simpler kafka consumer:	Dana Powers	More...				almost 11 years ago
Merge pull request #232 from dpkp/directory_layout	Dana Powers	More...				almost 11 years ago
Use b''.join([]) instead of += to speedup code	Dana Powers	More...				almost 11 years ago
Fixup test_context.py unittest import	Dana Powers	More...				almost 11 years ago
Merge pull request #217 from locationlabs/transaction	Dana Powers	More...				almost 11 years ago
Update python version support in README	Dana Powers	More...				almost 11 years ago
Separate consumers/producers/partitioners	Dana Powers	More...				almost 11 years ago
Add recent PR merges to Changelog for 0.9.3	Dana Powers	More...				almost 11 years ago
Bump version to 0.9.3-dev	Dana Powers	More...				almost 11 years ago
Merge pull request #223 from dpkp/metadata_refactor	Dana Powers	More...				almost 11 years ago
Updating AUTHORS.md with latest top contributors	David Arthur	More...				almost 11 years ago
Add six to tox.ini testing deps	Dana Powers	More...				almost 11 years ago
Merge pull request #227 from wizzat-feature/py3	Dana Powers	More...				almost 11 years ago
Merge pull request #221 from dpkp/minor_cleanups	Dana Powers	More...				almost 11 years ago
Merge pull request #222 from dpkp/fix_socket_timeout_test	Mark Roberts	More...				almost 11 years ago
Update kafka.util.crc32 to unsigned everywhere	Mark Roberts	More...				almost 11 years ago
Fix the multiprocessing tests for python 3	Mark Roberts	More...				almost 11 years ago
Fix test errors related to mocks	Mark Roberts	More...				almost 11 years ago
Merge branch 'feature/py3' of https://github.com/brutasse/kafka-python into feature/py3	Mark Roberts	More...				almost 11 years ago
Rename KafkaTransaction to OffsetCommitContext for clarity.	Jesse Myers	More...				almost 11 years ago

←
1
2
…
63
64
65
66
67
68
69
70
71
…
82
83
→