一个属于new consumer的配置项,出现在0.10及其以上版本中。
#一次调用poll()操作时返回的最大记录数,默认值为500
spring.kafka.consumer.max-poll-records;
Properties properties = new Properties();
properties.put("max.poll.records",2);

版权声明:本文为yangshengwei230612原创文章,遵循CC 4.0 BY-SA版权协议,转载请附上原文出处链接和本声明。