kafka消费指定每次最⼤消费消息数量ds kafka消费指定每次最⼤消费消息数量 ds
⼀个属于new consumer的配置项,出现在0.10及其以上版本中。
#⼀次调⽤poll()操作时返回的最⼤记录数,默认值为500
sumer.max-poll-records;
Properties properties = new Properties();
kafka最新版本properties.put("ds",2);

版权声明:本站内容均来自互联网,仅供演示用,请勿用于商业和其他非法用途。如果侵犯了您的权益请与我们联系QQ:729038198,我们将在24小时内删除。