查看“Java 自定义方法 - KAFKA”的源代码

Java 自定义函数 - KAFKA

=== 每次消费最大记录数 ===
 Properties props = new Properties();
 props.put("max.poll.records", N);
 ...
 consumer = new KafkaConsumer(props);
props 配置变化，需要 new consumer。当 N 较大时，需要相应设置 fetch.max.bytes。
 KafkaConsumer<String, String> consumer;
 consumer.poll(Duration.ofMillis(1000));
单位为毫秒，在指定时间内，最多消费 max.poll.records 记录。


[[分类:Develop]]
[[分类:Java]]