| Index | index by Group | index by Distribution | index by Vendor | index by creation date | index by Name | Mirrors | Help | Search |
| Name: python3-pykafka | Distribution: SUSE Linux Enterprise 15 SP6 |
| Version: 2.8.0 | Vendor: openSUSE |
| Release: bp156.3.2 | Build date: Wed Aug 2 09:33:34 2023 |
| Group: Development/Languages/Python | Build host: obs-arm-11 |
| Size: 1289871 | Source RPM: python-pykafka-2.8.0-bp156.3.2.src.rpm |
| Packager: https://bugs.opensuse.org | |
| Url: https://github.com/Parsely/pykafka | |
| Summary: Full-Featured Pure-Python Kafka Client | |
PyKafka is a cluster-aware Kafka>=0.8.2 client for Python. It includes Python implementations of Kafka producers and consumers, which are optionally backed by a C extension built on `librdkafka`_, and runs under Python 2.7+, Python 3.4+, and PyPy. .. _librdkafka: https://github.com/edenhill/librdkafka PyKafka's primary goal is to provide a similar level of abstraction to the `JVM Kafka client`_ using idioms familiar to Python programmers and exposing the most Pythonic API possible.
Apache-2.0
* Fri Dec 14 2018 Todd R <toddrme2178@gmail.com>
- Don't package tests in generic "tests" directory.
* Tue Dec 04 2018 Thomas Bechtold <tbechtold@suse.com>
- convert to singlespec
- use %license
- fix Requires
* Tue Dec 04 2018 Thomas Bechtold <tbechtold@suse.com>
- update to version 2.8.0:
* Do not log a retry if there are no more retries
* correct gen id
* Fix issues with NoneType when shutting down
* refactor to split out _start_broker_proc to spin up new kafka instances when needed
* treat magic offset integers as timestamps instead of raw offset values
* use new api version selection interface with metadatarequests and metadataresponses
* tests for OffsetFetchRequestV2/OffsetFetchResponseV2
* add parameter to balanced consumers
* fix protocol test bugs
* add reason to all new skipifs
* handle test-induced error a bit better
* stop relying on deprecated generationid
* change param name
* stub tests for new request/response
* do not autostart internal consumer, instead start it after setting consumer id
* catch nonodeerror when relinquishing partition
* upgrade pytest dependency
* use skip function instead of method decorator
* turn off new response for testing
* add test for partition offset commits
* use proper RDK flag
* clarify how partition_key is used in produce() doc
* Bump pytest from 3.7.0 to 3.7.1
* fix tests for py3
* change API_KEY to a class attribute on all protocol classes for use in utils.ApiVersionAware
* fix some errors in metadataresponse subclass population
* set controller broker from metadata response
* can't use fstrings in py2
* fix infinite wait logic for gevent
* pass broker version to KafkaClient in SSL tests
* add tests for new ListOffsetRequestV1
* add version suport information for older broker versions
* offset validation in reset_offsets
* fix last few skips
* add api_version to OffsetFetchRequest/OffsetFetchResponse
* increment version string for 2.7.0-dev.2
* XXX comment for future
* test for valid timestamp value
* make mark_as_delivered an instance method to allow monkeypatching in tests
* documentation warnings about autocommit
* increment version string for 2.7.0
* call cleanup() in fetch instead of autocommitter
* update packaging isntructions
* don't allow _wait_all to block indefinitely
* pin gevent requirement to avoid breaking kazoo import
* remove ancient readme note about samsa
* implement all versions of MetadataRequest
* update documentation to reflect type change
* fix iteration over owned_partition_offets
* convert bytes to str before encoding for py3 compat
* deprecate BalancedConsumer.zookeeper_connect and rename to zookeeper_hosts for standardization. fixes #920
* split out has_message wait for clearer separation of concerns
* don't remove start kwarg
* change uses of OffsetRequest to ListOffsetRequest
* use lock context manager now that we never have to lock/unlock on retries
* remove unused imports from producer
* add InvalidTopic exception. fixes #846
* Replace other instances of iteritems for PY3 compatibility
* xfail commonly failing tests
* update kazoo / gevent dependencies
* increment version for 2.8.0
* fix exception formatting bug
* add note on connection loss handling to usage guide
* separate offset requesting and offset resetting/partition locking into two separate blocks to clarify and deduplicate the reset_offsets() function
* use a default timeout value that doesn't trigger an error
* raise custom exception for better self-description
* fix last_n_messages example
* warning -> info for api version message
* fix off-by-one
* only fetch api versions once to avoid costly requests on update()
* add the rest of the missing implementations to the protocol module and fix a handful of missing imports
* implement all six versions of MetadataResponse
* pass integer timestamps to PartitionOffsetRequest
* descriptive error message for buffer decode failures. fixes #598
* Bump pytest from 3.7.2 to 3.7.3
* allow broker_version to be specified via cli
* Retry 3 times by default to connect to the broker
* default queue empty wait to 0 to mimic previous behavior
* add test of serde
* add test to ensure sync producer raises an exception when messages are not marked as delivered
* update changelog for 2.8.0-dev.1
* fix typo in changelog[
* Bump lz4 from 2.0.1 to 2.0.2
* README updates
* fix missing or incorrect imports
* add args to other consumer classes and docstrings
* Bump pytest from 3.7.4 to 3.8.1
* skip legacy ssl wrapper test because of unresolved crashes
* implement kafka_tools.delete_topic
* add kwargs to rdkafka components
* missing imports
* improve logging and retry logic when broker is unreachable
* update tox gevent requirement
* Bump pytest from 3.6.3 to 3.6.4
* remove initial generationid set
* add test cache to gitignore
* add serialize/deserialize hooks in producer and consumer to allow custom encodings
* stop/start the linger/flush cycle based on queue emptiness
* Bump xxhash from 1.1.0 to 1.2.0
* Add test for retrying connection
* add missing docstrings
* handle magic offset integers in build_offset_request
* changelog updates for 2.7.0
* add tests for earlier versions of FetchResponse. fixes #695
* use ListOffsetResponseV1 where appropriate
* note about flush bug
* add test to ensure that unicode strings for consumer groups do not cause explosions
* gate controller broker setting on controller_id being set
* Bump pytest from 3.7.1 to 3.7.2
* implement ListOffsetResponseV1
* add param to rdkafka simpleconsumer
* Test against Kafka 1.0.1 rather than 1.0.0
* Prevent attempts to reset the offset when trying to fetch consumer lag.
* add ability to specify offset in build_offset_commit_request
* fix internal logic in SimpleConsumer.reset_offsets to be more user-friendly have saner defaults
* docstrings for stock serde
* some logging improvements and a test of the timestamp reset functionality
* remove unused imports to trigger travis build
* fix broker version restriction on topic creation/deletion to match reality
* add blank version 2.8.0-dev.5 to fix pypi duplicated upload name error
* Bump pytest from 3.7.3 to 3.7.4
* typo
* Minor typo fix
* add readme note about assignment strategies
* add long description to pypi info
* use library get_string fn instead of simple str()
* update issue template with note about duplicates
* fix typo in hardcoded api version specs
* update ApiVersionsResponse to use ApiVersionAware mixin
* add protocol tests for all versions of metadatarequest and metadataresponse
* add partition_offsets kwarg to SimpleConsumer.commit_offsets
* increment dev version
* stub version classes for metadataresponse
* skipid -> skip for rdkafka simpleconsumer tst
* add partition_offsets kwarg to BalancedConsumer.commit_offsets for consistency
* fix rdkafka producer test
* implement ListOffsetRequestV1 and change OffsetRequest to ListOffsetRequest
* set up protocol module, move admin and fetch to it
* implement topic delete request and response protocol
* non-code style nitpicks in message.py
* pykafka-816 : Fix for CPU issue seen in _produce because of metadata update failure
* more consistent kwarg naming
* OffsetFetchResponseV2 fix: top level error_code was not parsed
* fix param name
* make infinite waiting on empty queue configurable
* add note about design
* fix relative imports for py3
* add coding
* in-depth docstring explanation of how the ListOffsets API works
* raise error when no response was found for api version discovery
* skip-f -> skip
* use logging.NullHandler to kill nuisance messages about no handlers found. fixes #772
* disable new listoffsetrequest for now, since it requires new message format
* Bump pytest from 3.6.4 to 3.7.0
* add test for ApiVersionsRequest
* changelog for 2.8.0
* set consumer_id outside of init
* skip tests on travis for now
* explanatory docs about the new param
* create interface to work around missing kwarg on simpleconsumer
* changelog for 2.8.0-dev.2
* changelog for 2.8.0-dev.3
* changelog for 2.8.0-dev.4
* handle datetimes as offsets_before in fetch_offset_limit(s) calls
* add test for apiversionsresponse
* Bump lz4 from 0.10.1 to 2.0.1
* pass a null array to metadatarequest >=v1 to indicate all topics
* Bump lz4 from 2.0.2 to 2.1.0
* bytes for py3 tests
* only add brokers to replicas set that the cluster is aware of
* update changelog for 2.7.0-dev.2
* define epoch in common for timestamp building
* turn off new version as a test
* reset versions, use correct namedtuple typename
* move base definitions to base.py to avoid circular imports
* another skipif -> skip
* use cluster.controller_broker to send topic creation request to the proper broker
* encode consumer groups and topic names as ascii bytestrings
* allow pending_timeout_ms=-1 to denote indefinite blocking
* fix base class implementation of get_versions, for use in ApiVersionAware
* unit tests for topics api requests/responses
* implement Broker.delete_topics
* remove protocol.py
* Bump xxhash from 1.0.1 to 1.1.0
* add "last N messages" example to usage guide. fixes #829
* add noqa markers throughout protocol tests to make linting more usable
* fix broken test
* raise ProduceFailureError when delivery report is not found after timeout
* basic implementation of retrying BrokerConnection, pending tests
* Thu Feb 09 2017 dmueller@suse.com
- Initial packaging (2.5.0)
/etc/alternatives/kafka-tools /usr/bin/kafka-tools /usr/bin/kafka-tools-3.6 /usr/lib64/python3.6/site-packages/pykafka /usr/lib64/python3.6/site-packages/pykafka-2.8.0-py3.6.egg-info /usr/lib64/python3.6/site-packages/pykafka-2.8.0-py3.6.egg-info/PKG-INFO /usr/lib64/python3.6/site-packages/pykafka-2.8.0-py3.6.egg-info/SOURCES.txt /usr/lib64/python3.6/site-packages/pykafka-2.8.0-py3.6.egg-info/dependency_links.txt /usr/lib64/python3.6/site-packages/pykafka-2.8.0-py3.6.egg-info/entry_points.txt /usr/lib64/python3.6/site-packages/pykafka-2.8.0-py3.6.egg-info/not-zip-safe /usr/lib64/python3.6/site-packages/pykafka-2.8.0-py3.6.egg-info/requires.txt /usr/lib64/python3.6/site-packages/pykafka-2.8.0-py3.6.egg-info/top_level.txt /usr/lib64/python3.6/site-packages/pykafka/__init__.py /usr/lib64/python3.6/site-packages/pykafka/__pycache__ /usr/lib64/python3.6/site-packages/pykafka/__pycache__/__init__.cpython-36.opt-1.pyc /usr/lib64/python3.6/site-packages/pykafka/__pycache__/__init__.cpython-36.pyc /usr/lib64/python3.6/site-packages/pykafka/__pycache__/balancedconsumer.cpython-36.opt-1.pyc /usr/lib64/python3.6/site-packages/pykafka/__pycache__/balancedconsumer.cpython-36.pyc /usr/lib64/python3.6/site-packages/pykafka/__pycache__/broker.cpython-36.opt-1.pyc /usr/lib64/python3.6/site-packages/pykafka/__pycache__/broker.cpython-36.pyc /usr/lib64/python3.6/site-packages/pykafka/__pycache__/client.cpython-36.opt-1.pyc /usr/lib64/python3.6/site-packages/pykafka/__pycache__/client.cpython-36.pyc /usr/lib64/python3.6/site-packages/pykafka/__pycache__/cluster.cpython-36.opt-1.pyc /usr/lib64/python3.6/site-packages/pykafka/__pycache__/cluster.cpython-36.pyc /usr/lib64/python3.6/site-packages/pykafka/__pycache__/common.cpython-36.opt-1.pyc /usr/lib64/python3.6/site-packages/pykafka/__pycache__/common.cpython-36.pyc /usr/lib64/python3.6/site-packages/pykafka/__pycache__/connection.cpython-36.opt-1.pyc /usr/lib64/python3.6/site-packages/pykafka/__pycache__/connection.cpython-36.pyc /usr/lib64/python3.6/site-packages/pykafka/__pycache__/exceptions.cpython-36.opt-1.pyc /usr/lib64/python3.6/site-packages/pykafka/__pycache__/exceptions.cpython-36.pyc /usr/lib64/python3.6/site-packages/pykafka/__pycache__/handlers.cpython-36.opt-1.pyc /usr/lib64/python3.6/site-packages/pykafka/__pycache__/handlers.cpython-36.pyc /usr/lib64/python3.6/site-packages/pykafka/__pycache__/managedbalancedconsumer.cpython-36.opt-1.pyc /usr/lib64/python3.6/site-packages/pykafka/__pycache__/managedbalancedconsumer.cpython-36.pyc /usr/lib64/python3.6/site-packages/pykafka/__pycache__/membershipprotocol.cpython-36.opt-1.pyc /usr/lib64/python3.6/site-packages/pykafka/__pycache__/membershipprotocol.cpython-36.pyc /usr/lib64/python3.6/site-packages/pykafka/__pycache__/partition.cpython-36.opt-1.pyc /usr/lib64/python3.6/site-packages/pykafka/__pycache__/partition.cpython-36.pyc /usr/lib64/python3.6/site-packages/pykafka/__pycache__/partitioners.cpython-36.opt-1.pyc /usr/lib64/python3.6/site-packages/pykafka/__pycache__/partitioners.cpython-36.pyc /usr/lib64/python3.6/site-packages/pykafka/__pycache__/producer.cpython-36.opt-1.pyc /usr/lib64/python3.6/site-packages/pykafka/__pycache__/producer.cpython-36.pyc /usr/lib64/python3.6/site-packages/pykafka/__pycache__/simpleconsumer.cpython-36.opt-1.pyc /usr/lib64/python3.6/site-packages/pykafka/__pycache__/simpleconsumer.cpython-36.pyc /usr/lib64/python3.6/site-packages/pykafka/__pycache__/topic.cpython-36.opt-1.pyc /usr/lib64/python3.6/site-packages/pykafka/__pycache__/topic.cpython-36.pyc /usr/lib64/python3.6/site-packages/pykafka/balancedconsumer.py /usr/lib64/python3.6/site-packages/pykafka/broker.py /usr/lib64/python3.6/site-packages/pykafka/cli /usr/lib64/python3.6/site-packages/pykafka/cli/__init__.py /usr/lib64/python3.6/site-packages/pykafka/cli/__main__.py /usr/lib64/python3.6/site-packages/pykafka/cli/__pycache__ /usr/lib64/python3.6/site-packages/pykafka/cli/__pycache__/__init__.cpython-36.opt-1.pyc /usr/lib64/python3.6/site-packages/pykafka/cli/__pycache__/__init__.cpython-36.pyc /usr/lib64/python3.6/site-packages/pykafka/cli/__pycache__/__main__.cpython-36.opt-1.pyc /usr/lib64/python3.6/site-packages/pykafka/cli/__pycache__/__main__.cpython-36.pyc /usr/lib64/python3.6/site-packages/pykafka/cli/__pycache__/kafka_tools.cpython-36.opt-1.pyc /usr/lib64/python3.6/site-packages/pykafka/cli/__pycache__/kafka_tools.cpython-36.pyc /usr/lib64/python3.6/site-packages/pykafka/cli/kafka_tools.py /usr/lib64/python3.6/site-packages/pykafka/client.py /usr/lib64/python3.6/site-packages/pykafka/cluster.py /usr/lib64/python3.6/site-packages/pykafka/common.py /usr/lib64/python3.6/site-packages/pykafka/connection.py /usr/lib64/python3.6/site-packages/pykafka/exceptions.py /usr/lib64/python3.6/site-packages/pykafka/handlers.py /usr/lib64/python3.6/site-packages/pykafka/managedbalancedconsumer.py /usr/lib64/python3.6/site-packages/pykafka/membershipprotocol.py /usr/lib64/python3.6/site-packages/pykafka/partition.py /usr/lib64/python3.6/site-packages/pykafka/partitioners.py /usr/lib64/python3.6/site-packages/pykafka/producer.py /usr/lib64/python3.6/site-packages/pykafka/protocol /usr/lib64/python3.6/site-packages/pykafka/protocol/__init__.py /usr/lib64/python3.6/site-packages/pykafka/protocol/__pycache__ /usr/lib64/python3.6/site-packages/pykafka/protocol/__pycache__/__init__.cpython-36.opt-1.pyc /usr/lib64/python3.6/site-packages/pykafka/protocol/__pycache__/__init__.cpython-36.pyc /usr/lib64/python3.6/site-packages/pykafka/protocol/__pycache__/admin.cpython-36.opt-1.pyc /usr/lib64/python3.6/site-packages/pykafka/protocol/__pycache__/admin.cpython-36.pyc /usr/lib64/python3.6/site-packages/pykafka/protocol/__pycache__/base.cpython-36.opt-1.pyc /usr/lib64/python3.6/site-packages/pykafka/protocol/__pycache__/base.cpython-36.pyc /usr/lib64/python3.6/site-packages/pykafka/protocol/__pycache__/fetch.cpython-36.opt-1.pyc /usr/lib64/python3.6/site-packages/pykafka/protocol/__pycache__/fetch.cpython-36.pyc /usr/lib64/python3.6/site-packages/pykafka/protocol/__pycache__/group_membership.cpython-36.opt-1.pyc /usr/lib64/python3.6/site-packages/pykafka/protocol/__pycache__/group_membership.cpython-36.pyc /usr/lib64/python3.6/site-packages/pykafka/protocol/__pycache__/message.cpython-36.opt-1.pyc /usr/lib64/python3.6/site-packages/pykafka/protocol/__pycache__/message.cpython-36.pyc /usr/lib64/python3.6/site-packages/pykafka/protocol/__pycache__/metadata.cpython-36.opt-1.pyc /usr/lib64/python3.6/site-packages/pykafka/protocol/__pycache__/metadata.cpython-36.pyc /usr/lib64/python3.6/site-packages/pykafka/protocol/__pycache__/offset.cpython-36.opt-1.pyc /usr/lib64/python3.6/site-packages/pykafka/protocol/__pycache__/offset.cpython-36.pyc /usr/lib64/python3.6/site-packages/pykafka/protocol/__pycache__/offset_commit.cpython-36.opt-1.pyc /usr/lib64/python3.6/site-packages/pykafka/protocol/__pycache__/offset_commit.cpython-36.pyc /usr/lib64/python3.6/site-packages/pykafka/protocol/__pycache__/produce.cpython-36.opt-1.pyc /usr/lib64/python3.6/site-packages/pykafka/protocol/__pycache__/produce.cpython-36.pyc /usr/lib64/python3.6/site-packages/pykafka/protocol/admin.py /usr/lib64/python3.6/site-packages/pykafka/protocol/base.py /usr/lib64/python3.6/site-packages/pykafka/protocol/fetch.py /usr/lib64/python3.6/site-packages/pykafka/protocol/group_membership.py /usr/lib64/python3.6/site-packages/pykafka/protocol/message.py /usr/lib64/python3.6/site-packages/pykafka/protocol/metadata.py /usr/lib64/python3.6/site-packages/pykafka/protocol/offset.py /usr/lib64/python3.6/site-packages/pykafka/protocol/offset_commit.py /usr/lib64/python3.6/site-packages/pykafka/protocol/produce.py /usr/lib64/python3.6/site-packages/pykafka/rdkafka /usr/lib64/python3.6/site-packages/pykafka/rdkafka/__init__.py /usr/lib64/python3.6/site-packages/pykafka/rdkafka/__pycache__ /usr/lib64/python3.6/site-packages/pykafka/rdkafka/__pycache__/__init__.cpython-36.opt-1.pyc /usr/lib64/python3.6/site-packages/pykafka/rdkafka/__pycache__/__init__.cpython-36.pyc /usr/lib64/python3.6/site-packages/pykafka/rdkafka/__pycache__/helpers.cpython-36.opt-1.pyc /usr/lib64/python3.6/site-packages/pykafka/rdkafka/__pycache__/helpers.cpython-36.pyc /usr/lib64/python3.6/site-packages/pykafka/rdkafka/__pycache__/producer.cpython-36.opt-1.pyc /usr/lib64/python3.6/site-packages/pykafka/rdkafka/__pycache__/producer.cpython-36.pyc /usr/lib64/python3.6/site-packages/pykafka/rdkafka/__pycache__/simple_consumer.cpython-36.opt-1.pyc /usr/lib64/python3.6/site-packages/pykafka/rdkafka/__pycache__/simple_consumer.cpython-36.pyc /usr/lib64/python3.6/site-packages/pykafka/rdkafka/_rd_kafkamodule.c /usr/lib64/python3.6/site-packages/pykafka/rdkafka/helpers.py /usr/lib64/python3.6/site-packages/pykafka/rdkafka/producer.py /usr/lib64/python3.6/site-packages/pykafka/rdkafka/simple_consumer.py /usr/lib64/python3.6/site-packages/pykafka/simpleconsumer.py /usr/lib64/python3.6/site-packages/pykafka/test /usr/lib64/python3.6/site-packages/pykafka/test/__init__.py /usr/lib64/python3.6/site-packages/pykafka/test/__pycache__ /usr/lib64/python3.6/site-packages/pykafka/test/__pycache__/__init__.cpython-36.opt-1.pyc /usr/lib64/python3.6/site-packages/pykafka/test/__pycache__/__init__.cpython-36.pyc /usr/lib64/python3.6/site-packages/pykafka/test/__pycache__/kafka_instance.cpython-36.opt-1.pyc /usr/lib64/python3.6/site-packages/pykafka/test/__pycache__/kafka_instance.cpython-36.pyc /usr/lib64/python3.6/site-packages/pykafka/test/__pycache__/utils.cpython-36.opt-1.pyc /usr/lib64/python3.6/site-packages/pykafka/test/__pycache__/utils.cpython-36.pyc /usr/lib64/python3.6/site-packages/pykafka/test/kafka_instance.py /usr/lib64/python3.6/site-packages/pykafka/test/utils.py /usr/lib64/python3.6/site-packages/pykafka/topic.py /usr/lib64/python3.6/site-packages/pykafka/utils /usr/lib64/python3.6/site-packages/pykafka/utils/__init__.py /usr/lib64/python3.6/site-packages/pykafka/utils/__pycache__ /usr/lib64/python3.6/site-packages/pykafka/utils/__pycache__/__init__.cpython-36.opt-1.pyc /usr/lib64/python3.6/site-packages/pykafka/utils/__pycache__/__init__.cpython-36.pyc /usr/lib64/python3.6/site-packages/pykafka/utils/__pycache__/compat.cpython-36.opt-1.pyc /usr/lib64/python3.6/site-packages/pykafka/utils/__pycache__/compat.cpython-36.pyc /usr/lib64/python3.6/site-packages/pykafka/utils/__pycache__/compression.cpython-36.opt-1.pyc /usr/lib64/python3.6/site-packages/pykafka/utils/__pycache__/compression.cpython-36.pyc /usr/lib64/python3.6/site-packages/pykafka/utils/__pycache__/error_handlers.cpython-36.opt-1.pyc /usr/lib64/python3.6/site-packages/pykafka/utils/__pycache__/error_handlers.cpython-36.pyc /usr/lib64/python3.6/site-packages/pykafka/utils/__pycache__/socket.cpython-36.opt-1.pyc /usr/lib64/python3.6/site-packages/pykafka/utils/__pycache__/socket.cpython-36.pyc /usr/lib64/python3.6/site-packages/pykafka/utils/__pycache__/struct_helpers.cpython-36.opt-1.pyc /usr/lib64/python3.6/site-packages/pykafka/utils/__pycache__/struct_helpers.cpython-36.pyc /usr/lib64/python3.6/site-packages/pykafka/utils/compat.py /usr/lib64/python3.6/site-packages/pykafka/utils/compression.py /usr/lib64/python3.6/site-packages/pykafka/utils/error_handlers.py /usr/lib64/python3.6/site-packages/pykafka/utils/socket.py /usr/lib64/python3.6/site-packages/pykafka/utils/struct_helpers.py /usr/share/licenses/python3-pykafka /usr/share/licenses/python3-pykafka/LICENSE
Generated by rpm2html 1.8.1
Fabrice Bellet, Tue Jul 9 20:14:19 2024