Время ожидания сеанса Kafka - PullRequest
Новая
       8

Время ожидания сеанса Kafka

0 голосов
/ 01 июля 2019

Я новичок в kafka, я пытаюсь использовать данные из kafka, используя python, который занимает 10 минут для обработки одного сообщения из очереди потребителя kafka.Я обнаружил, что одно и то же сообщение зацикливается и принимается снова и снова.Может ли кто-нибудь помочь мне решить эту проблему. 

consumer = KafkaConsumer(topic_name,
                         bootstrap_servers=['localhost'],auto_offset_reset='earliest',enable_auto_commit=True,group_id="tangoit",max_poll_records=1,session_timeout_ms=700000,request_timeout_ms=800000,heartbeat_interval_ms=233334)                      
count =1
while True:
    msg_pack = consumer.poll(max_records=1)
    for tp, messages in msg_pack.items():
        for message in messages:
            time.sleep(600) // instead of sleep message processing will happend and it take 10 min to process that message
...