потребитель потребляет одно и то же сообщение дважды только при запуске - PullRequest
Новая
       30

потребитель потребляет одно и то же сообщение дважды только при запуске

0 голосов
/ 24 мая 2019

При самом первом потреблении мой потребитель потребляет одно и то же сообщение дважды, это происходит только при первом потреблении, после этого оно потребляет только один раз.пожалуйста, проверьте исправления 

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