ByteMind
V2EX  ›  问与答

pykafka 生产者无法传输数据?

  •  
  •   ByteMind · Nov 5, 2021 · 745 views
    This topic created in 1675 days ago, the information mentioned may be changed or developed.

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

    pro.jpg

    com.jpg

    Supplement 1  ·  Nov 5, 2021
    解决了,是因为 c 盘 host 出问题了
    zhuyang
        1
    zhuyang  
       Nov 5, 2021
    # block until all async messages are sent
    producer.flush()

    或者 f = producer.send() 后 调用 f.get()
    ByteMind
        3
    ByteMind  
    OP
       Nov 5, 2021
    @zhuyang kafka.errors.KafkaTimeoutError: KafkaTimeoutError: Timeout after waiting for 3 secs.
    使用 f.get()就会出现这个错误
    About   ·   Help   ·   Advertise   ·   Blog   ·   API   ·   FAQ   ·   Solana   ·   818 Online   Highest 6679   ·     Select Language
    创意工作者们的社区
    World is powered by solitude
    VERSION: 3.9.8.5 · 36ms · UTC 21:24 · PVG 05:24 · LAX 14:24 · JFK 17:24
    ♥ Do have faith in what you're doing.