Java 自定义方法 - KAFKA：修订历史

跳到导航 跳到搜索

差异选择：选中要对比的版本的单选按钮，按Enter键或下方的按钮。
说明：（当前）=与最后版本之间的差异，（之前）=与上一版本之间的差异，小=小编辑。

2024年10月30日 (星期三)

2024年9月29日 (星期日)

2024年5月15日 (星期三)

2024年3月8日 (星期五)

2024年3月7日 (星期四)

2024年3月6日 (星期三)

  • 当前之前 17:422024年3月6日 (三) 17:42‎ 阿奔 讨论 贡献‎ 478字节 +478‎ 创建页面，内容为“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 …” 标签：可视化编辑：已切换
取自“https://mwbbs.eu.org/wiki/index.php/Java_自定义方法_-_KAFKA”