kafka消費指定每次最大消費消息數量 max.poll.records
一個屬於new consumer的配置項,出現在0.10及其以上版本中。
#一次調用poll()操作時返回的最大記錄數,默認值為500
spring.kafka.consumer.max-poll-records;
Properties properties = new Properties(); properties.put("max.poll.records",2);
一個屬於new consumer的配置項,出現在0.10及其以上版本中。
#一次調用poll()操作時返回的最大記錄數,默認值為500
spring.kafka.consumer.max-poll-records;
Properties properties = new Properties(); properties.put("max.poll.records",2);
本站轉載的文章為個人學習借鑒使用,本站對版權不負任何法律責任。如果侵犯了您的隱私權益,請聯系本站郵箱yoyou2525@163.com刪除。