Skip to content

Commit 9c44ef3

Browse files
dpkpdpkp
committed
Release 1.3.0
1 parent 79c9968 commit 9c44ef3

File tree

4 files changed

+120
-2
lines changed

4 files changed

+120
-2
lines changed

‎CHANGES.md

+56
Original file line numberDiff line numberDiff line change
@@ -1,3 +1,59 @@
1+
# 1.3.0 (Aug 4, 2016)
2+
3+
Incompatible Changes
4+
* Delete KafkaConnection class (dpkp 769)
5+
* Rename partition_assignment -> assignment in MemberMetadata for consistency
6+
* Move selectors34 and socketpair to kafka.vendor (dpkp 785)
7+
* Change api_version config to tuple; deprecate str with warning (dpkp 761)
8+
* Rename _DEFAULT_CONFIG -> DEFAULT_CONFIG in KafkaProducer (dpkp 788)
9+
10+
Improvements
11+
* Vendor six 1.10.0 to eliminate runtime dependency (dpkp 785)
12+
* Add KafkaProducer and KafkaConsumer.metrics() with instrumentation similar to java client (dpkp 754 / 772 / 794)
13+
* Support Sasl PLAIN authentication (larsjsol PR 779)
14+
* Add checksum and size to RecordMetadata and ConsumerRecord (KAFKA-3196 / 770 / 594)
15+
* Use MetadataRequest v1 for 0.10+ api_version (dpkp 762)
16+
* Fix KafkaConsumer autocommit for 0.8 brokers (dpkp 756 / 706)
17+
* Improve error logging (dpkp 760 / 759)
18+
* Adapt benchmark scripts from https://github.com/mrafayaleem/kafka-jython (dpkp 754)
19+
* Add api_version config to KafkaClient (dpkp 761)
20+
* New Metadata method with_partitions() (dpkp 787)
21+
* Use socket_options configuration to setsockopts(). Default TCP_NODELAY (dpkp 783)
22+
* Expose selector type as config option (dpkp 764)
23+
* Drain pending requests to the coordinator before initiating group rejoin (dpkp 798)
24+
* Send combined size and payload bytes to socket to avoid potentially split packets with TCP_NODELAY (dpkp 797)
25+
26+
Bugfixes
27+
* Ignore socket.error when checking for protocol out of sync prior to socket close (dpkp 792)
28+
* Fix offset fetch when partitions are manually assigned (KAFKA-3960 / 786)
29+
* Change pickle_method to use python3 special attributes (jpaulodit 777)
30+
* Fix ProduceResponse v2 throttle_time_ms
31+
* Always encode size with MessageSet (#771)
32+
* Avoid buffer overread when compressing messageset in KafkaProducer
33+
* Explicit format string argument indices for python 2.6 compatibility
34+
* Simplify RecordMetadata; short circuit callbacks (#768)
35+
* Fix autocommit when partitions assigned manually (KAFKA-3486 / #767 / #626)
36+
* Handle metadata updates during consumer rebalance (KAFKA-3117 / #766 / #701)
37+
* Add a consumer config option to exclude internal topics (KAFKA-2832 / #765)
38+
* Protect writes to wakeup socket with threading lock (#763 / #709)
39+
* Fetcher spending unnecessary time during metrics recording (KAFKA-3785)
40+
* Always use absolute_import (dpkp)
41+
42+
Test / Fixtures
43+
* Catch select errors while capturing test fixture logs
44+
* Fix consumer group test race condition (dpkp 795)
45+
* Retry fixture failures on a different port (dpkp 796)
46+
* Dump fixture logs on failure
47+
48+
Documentation
49+
* Fix misspelling of password (ssaamm 793)
50+
* Document the ssl_password config option (ssaamm 780)
51+
* Fix typo in KafkaConsumer documentation (ssaamm 775)
52+
* Expand consumer.fetcher inline comments
53+
* Update kafka configuration links -> 0.10.0.0 docs
54+
* Fixup metrics_sample_window_ms docstring in consumer
55+
56+
157
# 1.2.5 (July 15, 2016)
258

359
Bugfixes

‎docs/changelog.rst

+62
Original file line numberDiff line numberDiff line change
@@ -1,6 +1,68 @@
11
Changelog
22
=========
33

4+
1.3.0 (Aug 4, 2016)
5+
###################
6+
7+
Incompatible Changes
8+
--------------------
9+
* Delete KafkaConnection class (dpkp 769)
10+
* Rename partition_assignment -> assignment in MemberMetadata for consistency
11+
* Move selectors34 and socketpair to kafka.vendor (dpkp 785)
12+
* Change api_version config to tuple; deprecate str with warning (dpkp 761)
13+
* Rename _DEFAULT_CONFIG -> DEFAULT_CONFIG in KafkaProducer (dpkp 788)
14+
15+
Improvements
16+
------------
17+
* Vendor six 1.10.0 to eliminate runtime dependency (dpkp 785)
18+
* Add KafkaProducer and KafkaConsumer.metrics() with instrumentation similar to java client (dpkp 754 / 772 / 794)
19+
* Support Sasl PLAIN authentication (larsjsol PR 779)
20+
* Add checksum and size to RecordMetadata and ConsumerRecord (KAFKA-3196 / 770 / 594)
21+
* Use MetadataRequest v1 for 0.10+ api_version (dpkp 762)
22+
* Fix KafkaConsumer autocommit for 0.8 brokers (dpkp 756 / 706)
23+
* Improve error logging (dpkp 760 / 759)
24+
* Adapt benchmark scripts from https://github.com/mrafayaleem/kafka-jython (dpkp 754)
25+
* Add api_version config to KafkaClient (dpkp 761)
26+
* New Metadata method with_partitions() (dpkp 787)
27+
* Use socket_options configuration to setsockopts(). Default TCP_NODELAY (dpkp 783)
28+
* Expose selector type as config option (dpkp 764)
29+
* Drain pending requests to the coordinator before initiating group rejoin (dpkp 798)
30+
* Send combined size and payload bytes to socket to avoid potentially split packets with TCP_NODELAY (dpkp 797)
31+
32+
Bugfixes
33+
--------
34+
* Ignore socket.error when checking for protocol out of sync prior to socket close (dpkp 792)
35+
* Fix offset fetch when partitions are manually assigned (KAFKA-3960 / 786)
36+
* Change pickle_method to use python3 special attributes (jpaulodit 777)
37+
* Fix ProduceResponse v2 throttle_time_ms
38+
* Always encode size with MessageSet (#771)
39+
* Avoid buffer overread when compressing messageset in KafkaProducer
40+
* Explicit format string argument indices for python 2.6 compatibility
41+
* Simplify RecordMetadata; short circuit callbacks (#768)
42+
* Fix autocommit when partitions assigned manually (KAFKA-3486 / #767 / #626)
43+
* Handle metadata updates during consumer rebalance (KAFKA-3117 / #766 / #701)
44+
* Add a consumer config option to exclude internal topics (KAFKA-2832 / #765)
45+
* Protect writes to wakeup socket with threading lock (#763 / #709)
46+
* Fetcher spending unnecessary time during metrics recording (KAFKA-3785)
47+
* Always use absolute_import (dpkp)
48+
49+
Test / Fixtures
50+
---------------
51+
* Catch select errors while capturing test fixture logs
52+
* Fix consumer group test race condition (dpkp 795)
53+
* Retry fixture failures on a different port (dpkp 796)
54+
* Dump fixture logs on failure
55+
56+
Documentation
57+
-------------
58+
* Fix misspelling of password (ssaamm 793)
59+
* Document the ssl_password config option (ssaamm 780)
60+
* Fix typo in KafkaConsumer documentation (ssaamm 775)
61+
* Expand consumer.fetcher inline comments
62+
* Update kafka configuration links -> 0.10.0.0 docs
63+
* Fixup metrics_sample_window_ms docstring in consumer
64+
65+
466
1.2.5 (July 15, 2016)
567
#####################
668

‎kafka/version.py

+1-1
Original file line numberDiff line numberDiff line change
@@ -1 +1 @@
1-
__version__ = '1.2.6.dev'
1+
__version__ = '1.3.0'

‎setup.py

+1-1
Original file line numberDiff line numberDiff line change
@@ -46,7 +46,7 @@ def run(cls):
4646
long_description=README,
4747
keywords="apache kafka",
4848
classifiers=[
49-
"Development Status :: 4 - Beta",
49+
"Development Status :: 5 - Production/Stable",
5050
"Intended Audience :: Developers",
5151
"License :: OSI Approved :: Apache Software License",
5252
"Programming Language :: Python",

0 commit comments

Comments
 (0)