直接通过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 > 1 * 60:
print('超时,退出')
break
msg = consume.poll(1000, 1) # 看上去,进程是一直等候在这里
print(count)
1
freshgoose 2021-06-18 21:33:08 +08:00
这也是敏感词吗……
|
2
css3 OP @freshgoose 不是,自动分类到 ka 板块了,求助没人看😂
|
3
youngce 2021-06-18 21:37:11 +08:00
api_version=(0,1,0)?
|
4
shicheng1993 2021-06-18 21:40:43 +08:00
用 RocketMQ 好像遇到过类似的问题,因为个人水平问题,用间接的方式解决了。
子进程进行消费并记录最后消费时间,主进程死循环,查看每个子进程消费时间,超时则重启子进程。不求甚解可以试试,O(∩_∩)O~ |