1
2
3
4
5
6
7
8
9
| from pykafka import KafkaClient
client = KafkaClient(hosts="localhost:9092")
topic = client.topics['maoyan_wish']
consumer = topic.get_simple_consumer(consumer_group='test', auto_commit_enable=True, consumer_id='test')
for message in consumer:
if message is not None:
print(message.offset, message.value)
|
