V2EX = way to explore
V2EX 是一个关于分享和探索的地方
现在注册
已注册用户请  登录
V2EX 提问指南
perpetually
V2EX  ›  问与答

pykafka 生产者无法传输数据?

  •  
  •   perpetually · 2021-11-05 09:34:11 +08:00 · 459 次点击
    这是一个创建于 1148 天前的主题,其中的信息可能已经有所发展或是发生改变。

    用 python 的 kafka 给后台传数据,明明没有任何异常,数据也正常传输了,但是消费者一直在等待,没有数据,后台也没看到数据,是我哪里设置出错了么?

    pro.jpg

    com.jpg

    第 1 条附言  ·  2021-11-05 11:23:44 +08:00
    解决了,是因为 c 盘 host 出问题了
    zhuyang
        1
    zhuyang  
       2021-11-05 10:20:22 +08:00
    # block until all async messages are sent
    producer.flush()

    或者 f = producer.send() 后 调用 f.get()
    zhuyang
        2
    zhuyang  
       2021-11-05 10:20:49 +08:00
    perpetually
        3
    perpetually  
    OP
       2021-11-05 11:01:50 +08:00
    @zhuyang kafka.errors.KafkaTimeoutError: KafkaTimeoutError: Timeout after waiting for 3 secs.
    使用 f.get()就会出现这个错误
    关于   ·   帮助文档   ·   博客   ·   API   ·   FAQ   ·   实用小工具   ·   2789 人在线   最高记录 6679   ·     Select Language
    创意工作者们的社区
    World is powered by solitude
    VERSION: 3.9.8.5 · 21ms · UTC 00:06 · PVG 08:06 · LAX 16:06 · JFK 19:06
    Developed with CodeLauncher
    ♥ Do have faith in what you're doing.