| AArch64 | |
| ppc64le | |
| s390x | |
| x86-64 |
- Don't package tests in generic "tests" directory.
- convert to singlespec - use %license - fix Requires
- 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
- Initial packaging (2.5.0)