我是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
暂无答案!
目前还没有任何答案,快来回答吧!