Bumpversion 0.1.4. Updated Kafka to 0.10.1 and kafka-python to 1.3.1 …

…support, ie upstream

CHANGES.rst

@@ -1,6 +1,18 @@
 CHANGES
 --------
 
+0.1.4 (2016-11-07)
+^^^^^^^^^^^^^^^^^^
+
+* Bumped python-kafka version to 1.3.1 and Kafka to 0.10.1.0.
+* Fixed auto version detection, to correctly handle 0.10.0.0 version
+* Updated Fetch and Produce requests to use v2 with v0.10.0 message format on brokers.
+This allows a ``timestamp`` to be associated with messages.
+* Changed lz4 compression framing, as it was changed due to KIP-57 in new message format.
+* Minor refactorings
+
+Big thanks to @fabregas for the hard work on this release (PR #60)
+
 0.1.3 (2016-10-18)
 ^^^^^^^^^^^^^^^^^^
 

aiokafka/__init__.py

@@ -6,7 +6,7 @@
 import sys  # noqa
 PY_35 = sys.version_info >= (3, 5)
 
-__version__ = '0.1.3'
+__version__ = '0.1.4'
 
 from .client import AIOKafkaClient  # noqa
 from .producer import AIOKafkaProducer  # noqa

tests/test_client.py

@@ -29,7 +29,7 @@ def test_init_with_list(self):
             loop=self.loop, bootstrap_servers=[
                 '127.0.0.1:9092', '127.0.0.2:9092', '127.0.0.3:9092'])
         self.assertEqual(
-            '<AIOKafkaClient client_id=aiokafka-0.1.3>', client.__repr__())
+            '<AIOKafkaClient client_id=aiokafka-0.1.4>', client.__repr__())
         self.assertEqual(
             sorted([('127.0.0.1', 9092, socket.AF_INET),
                     ('127.0.0.2', 9092, socket.AF_INET),