Kafka会话超时问题

2guxujil  于 2021-06-04  发布在  Kafka
关注(0)|答案(0)|浏览(223)

我是Kafka的新手,我尝试使用python来使用Kafka的数据,这需要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

暂无答案!

目前还没有任何答案,快来回答吧!

相关问题