FIX #20

Author: hifly81

README.adoc

@@ -364,6 +364,38 @@ Group id group-XX - Consumer id: consumer-group-XX-1-421db3e2-6501-45b1-acfd-275
 Group id group-XX - Consumer id: consumer-group-XX-1-421db3e2-6501-45b1-acfd-275ce8d18368 - Topic: users_clicks - Partition: 1 - Offset: 0 - Key: frank - Value: 1
 ----
 
+=== Python Consumer
+
+Install python lib _confluent-kafka_:
+
+[source,bash]
+----
+pip install confluent-kafka
+----
+
+Create topic:
+
+[source,bash]
+----
+kafka-topics --bootstrap-server localhost:9092 --create --topic kafka-topic --replication-factor 1 --partitions 1
+----
+
+Run producer:
+
+[source,bash]
+----
+cd kafka-python-producer
+python producer.py
+----
+
+Run consumer:
+
+[source,bash]
+----
+cd kafka-python-consumer
+python consumer.py
+----
+
 == Admin & Management
 
 === Kafka CLI Tools

kafka-python-consumer/consumer.py

@@ -0,0 +1,21 @@
+from confluent_kafka import Consumer
+
+conf = {'bootstrap.servers': "localhost:9092", 'group.id': 'pythongroup', 'auto.offset.reset': 'earliest'}
+topic = 'test-python'
+
+consumer = Consumer(conf)
+
+consumer.subscribe([topic])
+
+while True:
+    msg = consumer.poll(1.0)
+
+    if msg is None:
+        continue
+    if msg.error():
+        print("Error: {}".format(msg.error()))
+        continue
+
+    print('Message: {}'.format(msg.value().decode('utf-8')))
+
+consumer.close()

kafka-python-producer/producer.py

@@ -11,7 +11,6 @@ def ack(error, message):
     print("offset={}".format(message.offset()))
 
 
-
 conf = {'bootstrap.servers': "localhost:9092"}
 
 producer = Producer(conf)