kafka client有个缓存,发少量消息,消费端未接收到,发多些消息,便可接收到,我想问下 这个设置的是 kafka 那个属性,
发表于 2018-09-04
kafka client有个缓存,发少量消息,消费端未接收到,发多些消息,便可接收到,我想问下 这个设置的是 kafka 那个属性,
kafka客户端默认是先放到缓存,然后在发送到kafka,你执行完成后,进程就结束了,导致缓存中的数据没有发送完。
1、producer.close(); 结束增加这个
2、增加休眠时间
客户端默认的缓存,具体指的是什么,kafka 那个属性 可以设置这个?就是这里不清楚。
单条消息发送不是慢么,kafka把要发的消息先放到队列里,做成一个批次,一个批次包含了2000条消息,批量发到kafka。
可参考:https://www.orchome.com/511
搜索buffer相关的。
非常感谢,虽然不是很明白,今天测试时,我 producer 先发10条消息,对方未收到;我 加大发送消息数量为800条,对方接收到消息,所以郁闷半天,没找到 具体那个属性设置的,batch.size 这个跟我实际发送的 字节数*条数 并不匹配,不理解啊
看下我给你的文档介绍吧。
你的答案