api - 消费者只在开始时两次消费相同的消息

Question

在第一次消费时，我的消费者两次消费相同的消息，这只发生在第一次消费时，之后它只消费一次。

---

附上下面的消费者配置代码。请检查更正

def __init__(self, group_id, topic='default', bootstrap_servers= 
['localhost:9092']):
        self.topic = topic
        self.bootstrap_servers = bootstrap_servers
        self.group_id = group_id
        self.consumer = KafkaConsumer(## Heading ##
            self.topic,
            bootstrap_servers=self.bootstrap_servers,
            auto_offset_reset='earliest',
            enable_auto_commit=True,
            group_id=self.group_id,
            value_deserializer=lambda x: loads(x.decode('utf-8')))

标签： apiapache-kafkakafka-consumer-apikafka-python