Spark Streaming进度分区独立

在一种情况下，我们已按帐号对输入的Kafka主题进行了划分。每个分区都直接写入数据库，并且彼此之间没有依赖性。

当前，即使一个分区在5秒钟内完成了处理，它也必须等待最慢的分区完成才能开始处理下一批。假设最慢的分区需要30秒，然后在5秒钟内完成的分区必须保持空闲状态25秒钟。

有没有一种方法可以设置微型批处理，在该批处理中我们依次处理每个分区并且独立于其他分区？在我的较早版本中，例如，在5秒内完成批处理的分区应该立即提取下一个批处理，而不要闲置25秒。