#!/usr/bin/env python
# coding=utf-8
"""
kafka的消费者不是线程安全的，不能多线程启用
kafka不像其他的MQ，消费完数据，直接丢掉，而是会默认存储7天，存储7天后自动清除，故而可以从头开始消费
从指定topic的partiotion的指定setoff开始消费
"""
import json
from kafka import KafkaConsumer
from kafka.structs import TopicPartition
consumer = KafkaConsumer(bootstrap_servers='192.168.137.200:9092',group_id='python3-consumer',
auto_offset_reset='earliest')
consumer.subscribe(['topic_elink'])
for message in consumer:
print(message)
