Python 消费 ka-f-a-k 时无限挂起，如何定位原因

[css3]

直接通过ka，fka 命令行是可以消费的，但通过 python 消费时，一直消费不到，进程也不超时，更换消费组，消费lastet最新 msg 也无响应， consume.poll(1000, 1) 第一个参数的 timeout 仿佛无效，设置了也是一直等待消费

import time
from kafka import KafkaConsumer

topic1 = 'additional_order'
host = '192.168.14.55:9092'


consume = KafkaConsumer(topic, group_id="group1", 
                              bootstrap_servers=host, auto_offset_reset='latest',
                              security_protocol='SASL_PLAINTEXT',
                              sasl_mechanism='PLAIN',
                              sasl_plain_username='admin',
                              sasl_plain_password='$%<a'
                              api_version=(0, 10)
                              )


while True:
    count += 1
    if time.time() - start_time &gt; 1 * 60:
        print('超时,退出')
        break
    msg = consume.poll(1000, 1)  # 看上去，进程是一直等候在这里
    print(count)

[freshgoose]

这也是敏感词吗……

[css3]

@freshgoose 不是，自动分类到 ka 板块了，求助没人看😂

[ynkkdev]

api_version=(0,1,0)？

[shicheng1993]

用 RocketMQ 好像遇到过类似的问题，因为个人水平问题，用间接的方式解决了。
子进程进行消费并记录最后消费时间，主进程死循环，查看每个子进程消费时间，超时则重启子进程。不求甚解可以试试，O(∩_∩)O~

[css3]

@youngce 这个影响不大吧？