spark + kafka 输入流 “spark.streaming.kafka.maxRatePerPartition”

spark + kafka inputstream "spark.streaming.kafka.maxRatePerPartition"

提问人：user3176131 提问时间：10/10/2023 更新时间：10/10/2023 访问量：9

问：

设置 spark.streaming.kafka.maxRatePerPartition：100 并摄取 10000 条记录，每秒应需要 100 条记录， 但消耗了所有 10000 条记录

Java 性能 apache-kafka 输入流

评论

答： 暂无答案

上一个：Java - 无法在 Windows 上删除 Process 的临时输出文件

下一个：为什么我总是收到“无法重试请求，因为无法重置请求流”？