Skip to content

Navigation Menu

Sign in
Appearance settings

Search code, repositories, users, issues, pull requests...

Provide feedback

We read every piece of feedback, and take your input very seriously.

Saved searches

Use saved searches to filter your results more quickly
Appearance settings

Commit 98b9d11

Browse filesBrowse files
dpkpdpkp
committed
Release 1.3.0
1 parent 79c9968 commit 98b9d11
Copy full SHA for 98b9d11

File tree

4 files changed

+120
-2
lines changed
Filter options

4 files changed

+120
-2
lines changed

‎CHANGES.md

Copy file name to clipboardExpand all lines: CHANGES.md
+56Lines changed: 56 additions & 0 deletions
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

Copy file name to clipboardExpand all lines: docs/changelog.rst
+62Lines changed: 62 additions & 0 deletions
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

Copy file name to clipboard
+1-1Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -1 +1 @@
1-
__version__ = '1.2.6.dev'
1+
__version__ = '1.3.0'

‎setup.py

Copy file name to clipboardExpand all lines: setup.py
+1-1Lines changed: 1 addition & 1 deletion
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",
5050
"Intended Audience :: Developers",
5151
"License :: OSI Approved :: Apache Software License",
5252
"Programming Language :: Python",

0 commit comments

Comments
0 (0)
Morty Proxy This is a proxified and sanitized view of the page, visit original site.