from kafka import KafkaConsumer
from kafka import KafkaProducer
consumer = KafkaConsumer('python_test', group_id='python',
    bootstrap_servers=['127.0.0.1:9092'], value_deserializer=lambda m: m.
    decode('utf-8'))
for msg in consumer:
    print(msg.value)

211949abab51751eefa81160c68d3830527d797b
<mask token>

<mask token>
for msg in consumer:
    print(msg.value)

<mask token>
consumer = KafkaConsumer('python_test', group_id='python',
    bootstrap_servers=['127.0.0.1:9092'], value_deserializer=lambda m: m.
    decode('utf-8'))
for msg in consumer:
    print(msg.value)

from kafka import KafkaConsumer
from kafka import KafkaProducer
consumer = KafkaConsumer('python_test', group_id='python',
    bootstrap_servers=['127.0.0.1:9092'], value_deserializer=lambda m: m.
    decode('utf-8'))
for msg in consumer:
    print(msg.value)
