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

pykafka 生产者无法传输数据?

  •  
  •   ByteMind · 2021 年 11 月 5 日 · 651 次点击
    这是一个创建于 1528 天前的主题,其中的信息可能已经有所发展或是发生改变。

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

    pro.jpg

    com.jpg

    第 1 条附言  ·  2021 年 11 月 5 日
    解决了,是因为 c 盘 host 出问题了
    zhuyang
        1
    zhuyang  
       2021 年 11 月 5 日
    # block until all async messages are sent
    producer.flush()

    或者 f = producer.send() 后 调用 f.get()
    ByteMind
        3
    ByteMind  
    OP
       2021 年 11 月 5 日
    @zhuyang kafka.errors.KafkaTimeoutError: KafkaTimeoutError: Timeout after waiting for 3 secs.
    使用 f.get()就会出现这个错误
    关于   ·   帮助文档   ·   自助推广系统   ·   博客   ·   API   ·   FAQ   ·   Solana   ·   933 人在线   最高记录 6679   ·     Select Language
    创意工作者们的社区
    World is powered by solitude
    VERSION: 3.9.8.5 · 24ms · UTC 22:40 · PVG 06:40 · LAX 14:40 · JFK 17:40
    ♥ Do have faith in what you're doing.