在第一次消费时，我的消费者消费同一条消息两次，这只发生在第一次消费时，之后它只消费一次。
在下面附加消费者配置代码。请检查是否有更正

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')))