Merge branch 'some_example_files'

CHANGES.rst

@@ -1,6 +1,11 @@
 CHANGES
 --------
 
+0.1.1 (2016-04-15)
+^^^^^^^^^^^^^^^^^^
+
+* Fix packaging issues. Removed unneded files from package.
+
 0.1.0 (2016-04-15)
 ^^^^^^^^^^^^^^^^^^
 

aiokafka/__init__.py

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

examples/simple_consumer.py

@@ -0,0 +1,17 @@
+from aiokafka import AIOKafkaConsumer
+import asyncio
+
+loop = asyncio.get_event_loop()
+
+async def consume():
+    consumer = AIOKafkaConsumer(
+        "my_topic", loop=loop, bootstrap_servers='localhost:9092')
+    # Get cluster layout and topic/partition allocation
+    await consumer.start()
+    try:
+        async for msg in consumer:
+            print(msg.value)
+    finally:
+        await consumer.stop()
+
+loop.run_until_complete(consume())

examples/simple_produce.py

@@ -0,0 +1,17 @@
+from aiokafka import AIOKafkaProducer
+import asyncio
+
+loop = asyncio.get_event_loop()
+
+async def send_one():
+    producer = AIOKafkaProducer(
+        loop=loop, bootstrap_servers='localhost:9092')
+    # Get cluster layout and topic/partition allocation
+    await producer.start()
+    try:
+        # Produce messages
+        await producer.send_and_wait("my_topic", b"Super message")
+    finally:
+        await producer.stop()
+
+loop.run_until_complete(send_one())

tests/test_client.py

@@ -26,7 +26,7 @@ def test_init_with_list(self):
             loop=self.loop,
             bootstrap_servers=['kafka01:9092', 'kafka02:9092', 'kafka03:9092'])
         self.assertEqual(
-            '<AIOKafkaClient client_id=aiokafka-0.1.0>', client.__repr__())
+            '<AIOKafkaClient client_id=aiokafka-0.1.1>', client.__repr__())
         self.assertEqual(sorted({'kafka01': 9092,
                                  'kafka02': 9092,
                                  'kafka03': 9092}.items()),