From d83ab627d77415719e4646101b9333522d8702e64a2a8297b3585b78843395d2 Mon Sep 17 00:00:00 2001 From: Thomas Bechtold Date: Mon, 14 Mar 2016 11:45:38 +0000 Subject: [PATCH] Accepting request 372756 from home:mmnelemane:branches:devel:languages:python Upgrading version to kafka-python-1.0.1 OBS-URL: https://build.opensuse.org/request/show/372756 OBS-URL: https://build.opensuse.org/package/show/devel:languages:python/python-kafka-python?expand=0&rev=2 --- kafka-python-0.9.4.tar.gz | 3 - kafka-python-1.0.1.tar.gz | 3 + python-kafka-python.changes | 107 ++++++++++++++++++++++++++++++++++++ python-kafka-python.spec | 4 +- 4 files changed, 112 insertions(+), 5 deletions(-) delete mode 100644 kafka-python-0.9.4.tar.gz create mode 100644 kafka-python-1.0.1.tar.gz diff --git a/kafka-python-0.9.4.tar.gz b/kafka-python-0.9.4.tar.gz deleted file mode 100644 index 0b32ab0..0000000 --- a/kafka-python-0.9.4.tar.gz +++ /dev/null @@ -1,3 +0,0 @@ -version https://git-lfs.github.com/spec/v1 -oid sha256:6cd463b688d98fec1c1f602e316eb7745aef0e55dc57fe9ff2f203cf0865c8c7 -size 63119 diff --git a/kafka-python-1.0.1.tar.gz b/kafka-python-1.0.1.tar.gz new file mode 100644 index 0000000..b13d297 --- /dev/null +++ b/kafka-python-1.0.1.tar.gz @@ -0,0 +1,3 @@ +version https://git-lfs.github.com/spec/v1 +oid sha256:ad7a27d247acaec2aa85b63c6f195a2007f802725baf51d45b56e1a11c2fc34d +size 150699 diff --git a/python-kafka-python.changes b/python-kafka-python.changes index caec93e..389083d 100644 --- a/python-kafka-python.changes +++ b/python-kafka-python.changes @@ -1,3 +1,110 @@ +------------------------------------------------------------------- +Mon Mar 14 10:03:55 UTC 2016 - mmnelemane@suse.com + +- Updated version to 1.0.1 + * Consumers: + * Add RangePartitionAssignor (and use as default); add assignor tests + (dpkp PR 550) + * Make sure all consumers are in same generation before stopping + group test + * Verify node ready before sending offset fetch request from + coordinator + * Improve warning when offset fetch request returns unknown + topic / partition + * KafkaConsumer re-written to emulate the new 0.9 kafka consumer + (java client) and support coordinated consumer groups + (feature requires >= 0.9.0.0 brokers) + * Methods no longer available: + * configure [initialize a new consumer instead] + * set_topic_partitions [use subscribe() or assign()] + * fetch_messages [use poll() or iterator interface] + * get_partition_offsets + * offsets [use committed(partition)] + * task_done [handled internally by auto-commit; or commit + offsets manually] + * Configuration changes (consistent with updated java client): + * lots of new configuration parameters -- see docs for details + * auto_offset_reset: previously values were 'smallest' or 'largest', + now values are 'earliest' or 'latest' + * fetch_wait_max_ms is now fetch_max_wait_ms + * max_partition_fetch_bytes is now max_partition_fetch_bytes + * deserializer_class is now value_deserializer and key_deserializer + * auto_commit_enable is now enable_auto_commit + * auto_commit_interval_messages was removed + * socket_timeout_ms was removed + * refresh_leader_backoff_ms was removed + * SimpleConsumer and MultiProcessConsumer are now deprecated and will be + removed in a future release. Users are encouraged to migrate to + KafkaConsumer. + * Initial support for consumer coordinator: offsets only + (toddpalino PR 420) + * Allow blocking until some messages are received in SimpleConsumer + (saaros PR 457) + * Support subclass config changes in KafkaConsumer (zackdever PR 446) + * Support retry semantics in MultiProcessConsumer (barricadeio PR 456) + * Support partition_info in MultiProcessConsumer (scrapinghub PR 418) + * Enable seek() to an absolute offset in SimpleConsumer (haosdent PR 412) + * Add KafkaConsumer.close() (ucarion PR 426) + * Producers + * Warn if pending batches failed during flush + * Fix concurrency bug in RecordAccumulator.ready() + * Fix bug in SimpleBufferPool memory condition waiting / timeout + * Support batch_size = 0 in producer buffers (dpkp PR 558) + * Catch duplicate batch.done() calls [e.g., maybe_expire then a response + errback] + * new producer class: KafkaProducer. Exposes the same interface as + official java client. Async by default; returned future.get() can be + called for synchronous blocking + * SimpleProducer is now deprecated and will be removed in a future + release. Users are encouraged to migrate to KafkaProducer. + * Catch client.reinit() exceptions in async producer (dpkp) + * Producer.stop() now blocks until async thread completes (dpkp PR 485) + * Catch errors during load_metadata_for_topics in async producer + (bschopman PR 467) + * Add compression-level support for codecs that support it (trbs PR 454) + * Fix translation of Java murmur2 code, fix byte encoding for Python 3 + (chrischamberlin PR 439) + * Only call stop() on not-stopped producer objects (docker-hub PR 435) + * Allow null payload for deletion feature (scrapinghub PR 409) + * Clients + * synchronous KafkaClient renamed to SimpleClient. For backwards + compatibility, you will get a SimpleClient via + `from kafka import KafkaClient`. This will change in a future release. + * All client calls use non-blocking IO under the hood. + * Add probe method check_version() to infer broker versions. + * Use non-blocking io for broker aware requests (ecanzonieri PR 473) + * Use debug logging level for metadata request (ecanzonieri PR 415) + * Catch KafkaUnavailableError in _send_broker_aware_request + (mutability PR 436) + * Lower logging level on replica not available and commit + (ecanzonieri PR 415) + * Documentation + * Improve kafka.cluster docstrings + * Migrate load_example.py to KafkaProducer / KafkaConsumer + * Updated README and sphinx documentation to address new classes. + * Docstring improvements to make python help() easier to use. + * Update docs and links wrt maintainer change (mumrah -> dpkp) + * Internals + * Dont override system rcvbuf or sndbuf unless configured explicitly + (dpkp PR 557) + * Some attributes may not exist in __del__ if we failed assertions + * Break up some circular references and close client wake pipes on __del__ + (aisch PR 554) + * Old protocol stack is deprecated. It has been moved to + kafka.protocol.legacy and may be removed in a future release. + * Protocol layer re-written using Type classes, Schemas and Structs + (modeled on the java client). + * Add support for LZ4 compression (including broken framing header + checksum). + * Add py35 to tox testing + * Update travis config to use container infrastructure + * Add 0.8.2.2 and 0.9.0.0 resources for integration tests; update default + official releases + * new pylint disables for pylint 1.5.1 (zackdever PR 481) + * Fix python3 / python2 comments re queue/Queue (dpkp) + * Add Murmur2Partitioner to kafka __all__ imports (dpkp Issue 471) + * Include LICENSE in PyPI sdist (koobs PR 441) + ------------------------------------------------------------------- Wed Sep 16 14:48:55 UTC 2015 - tbechtold@suse.com diff --git a/python-kafka-python.spec b/python-kafka-python.spec index e752783..79c16b8 100644 --- a/python-kafka-python.spec +++ b/python-kafka-python.spec @@ -1,7 +1,7 @@ # # spec file for package python-kafka-python # -# Copyright (c) 2015 SUSE LINUX GmbH, Nuernberg, Germany. +# Copyright (c) 2016 SUSE LINUX GmbH, Nuernberg, Germany. # # All modifications and additions to the file contributed by third parties # remain the property of their copyright owners, unless otherwise agreed @@ -17,7 +17,7 @@ Name: python-kafka-python -Version: 0.9.4 +Version: 1.0.1 Release: 0 Summary: Pure Python client for Apache Kafka License: Apache-2.0