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

big big world 发表于: 2018-09-04   最后更新时间: 2018-09-04 16:40:08   3,396 游览

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

发表于 2018-09-04
添加评论

kafka客户端默认是先放到缓存,然后在发送到kafka,你执行完成后,进程就结束了,导致缓存中的数据没有发送完。
1、producer.close(); 结束增加这个
2、增加休眠时间

客户端默认的缓存,具体指的是什么,kafka 那个属性 可以设置这个?就是这里不清楚。

单条消息发送不是慢么,kafka把要发的消息先放到队列里,做成一个批次,一个批次包含了2000条消息,批量发到kafka。
可参考:https://www.orchome.com/511
搜索buffer相关的。

非常感谢,虽然不是很明白,今天测试时,我 producer 先发10条消息,对方未收到;我 加大发送消息数量为800条,对方接收到消息,所以郁闷半天,没找到 具体那个属性设置的,batch.size 这个跟我实际发送的 字节数*条数 并不匹配,不理解啊

看下我给你的文档介绍吧。

你的答案

查看kafka相关的其他问题或提一个您自己的问题