kafka client 发送少量数据,消费端未接收到

kafka client有个缓存,发少量消息,消费端未接收到,发多些消息,便可接收到,我想问下 这个设置的是 kafka 那个属性,







发表于: 18天前   最后更新时间: 18天前   游览量:124
上一条: 到头了!
下一条: 已经是最后了!

评论…


  • kafka客户端默认是先放到缓存,然后在发送到kafka,你执行完成后,进程就结束了,导致缓存中的数据没有发送完。
    1、producer.close(); 结束增加这个
    2、增加休眠时间
    • 单条消息发送不是慢么,kafka把要发的消息先放到队列里,做成一个批次,一个批次包含了2000条消息,批量发到kafka。
      可参考:http://orchome.com/511
      搜索buffer相关的。
        • 非常感谢,虽然不是很明白,今天测试时,我 producer 先发10条消息,对方未收到;我 加大发送消息数量为800条,对方接收到消息,所以郁闷半天,没找到 具体那个属性设置的,batch.size 这个跟我实际发送的 字节数*条数 并不匹配,不理解啊
          • 评论…
            • in this conversation