Changelog for python-pykafka-2.8.0-3.15.x86_64.rpm :
Fri Dec 14 13:00:00 2018 toddrme2178AATTgmail.com
- Don\'t package tests in generic \"tests\" directory.

Tue Dec 4 13:00:00 2018 tbechtoldAATTsuse.com
- convert to singlespec
- use %license
- fix Requires

Tue Dec 4 13:00:00 2018 tbechtoldAATTsuse.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 9 13:00:00 2017 dmuellerAATTsuse.com
- Initial packaging (2.5.0)