P

Python client for Apache Kafka

Settings | Report Duplicate

0

I Use This!

Moderate Activity

Commits : Listings

Analyzed about 9 hours ago. based on code collected about 9 hours ago.

Commit Message	Contributor	Files Modified	Lines Added	Lines Removed	Code Location	Date
Aug 04, 2024 — Aug 04, 2025 Showing page 68 of 83 Search / Filter on:
Add client unit tests for has_metadata_for_topic and ensure_topic_exists	Dana Powers	More...				almost 11 years ago
Cleanup tests: no more import *; remove unused	Dana Powers	More...				almost 11 years ago
Merge pull request #216 from zever/nit-incorrect-except-format	Dana Powers	More...				almost 11 years ago
Add test for sending produce request to unknown topic w/o auto-creation	Dana Powers	More...				almost 11 years ago
Use standard exceptions in client._get_leader_for_partition() - drop custom PartitionUnavailable exception - raise UnknownTopicOrPartitionError or LeaderNotAvailableError - add tests for exception raises	Dana Powers	More...				almost 11 years ago
Raise UnknownTopicOrPartitionError immediately in ensure_topic_exists -- server is not auto-creating	Dana Powers	More...				almost 11 years ago
load_metadata_for_topics should raise exceptions on explicit topic args	Dana Powers	More...				almost 11 years ago
Dont need to use callbacks for offset fetch requests	Dana Powers	More...				almost 11 years ago
Refactor internal metadata dicts in KafkaClient - use helper methods not direct access - add get_partition_ids_for_topic - check for topic and partition errors during load_metadata_for_topics - raise LeaderNotAvailableError when topic is being auto-created or UnknownTopicOrPartitionError if auto-creation off	Dana Powers	More...				almost 11 years ago
No more custom LeaderUnavailableError exception -- raise LeaderNotAvailableError	Dana Powers	More...				almost 11 years ago
if error code is not recognized in check_error: raise UnknownError	Dana Powers	More...				almost 11 years ago
Rearrange KafkaClient method order to group client metadata methods together	Dana Powers	More...				almost 11 years ago
Improve metadata protocol handling - add MetadataRequest and MetadataResponse namedtuples - add TopicMetadata namedtuple - add error codes to Topic and Partition Metadata - add KafkaClient.send_metadata_request() method - KafkaProtocol.decode_metadata_response changed to return a MetadataResponse object so that it is consistent with server api: [broker_list, topic_list]	Dana Powers	More...				almost 11 years ago
Fix socket timeout test -- mock the side_effect	Dana Powers	More...				almost 11 years ago
Another attempt to fix failover test flapping	Dana Powers	More...				almost 11 years ago
Import cleanups in tests	Dana Powers	More...				almost 11 years ago
Add a little more detail to test instructions in README	Dana Powers	More...				almost 11 years ago
Add simple PyPI install instructions and link to releases in README	Dana Powers	More...				almost 11 years ago
Update README code examples to import from kafka not kafka.client, kafka.consumer, etc	Dana Powers	More...				almost 11 years ago
Minor import cleanups	Dana Powers	More...				almost 11 years ago
Change message type requirement from str to bytes for clarity and prep for python3	Dana Powers	More...				almost 11 years ago
Add trove classifiers for python 2.6, 2.7, and pypy to setup.py for PyPI	Dana Powers	More...				almost 11 years ago
Improve documentation in example	Jesse Myers	More...				almost 11 years ago
Add transaction context manager.	Jesse Myers	More...				almost 11 years ago
just fixing a silly except formatting mistake	Zack Dever	More...				almost 11 years ago
Fix more tests, only multiprocessing consumer ones remaining	Bruno Renié	More...				almost 11 years ago
Fix more tests, only multiprocessing consumer ones remaining	Bruno Renié	More...				almost 11 years ago
Bytes in self.msg()	Bruno Renié	More...				almost 11 years ago
Bytes in self.msg()	Bruno Renié	More...				almost 11 years ago
Use built-in next()	Bruno Renié	More...				almost 11 years ago

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