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 记录。