Is your feature request related to a problem? Please describe.
For the Pulsar-Spark connector, we want to implement Admission Control for Pulsar as a streaming source. The user should be able to specify the maximum number of bytes that can be processed per microbatch. If we are under the threshold for the number of bytes for this microbatch, we will process the next ledger in this partition.
Describe the solution you'd like
Design Doc
Essentially, for each microbatch, we check the average number of bytes per ledger. If we have capacity left in this microbatch (ie. are under the threshold), then we will admit the next ledger
Describe alternatives you've considered
In the driver, we prefetch the ledgers and cache them, but this leads to both latency and memory overhead. Correctness issues can also arise with this solution
Is your feature request related to a problem? Please describe.
For the Pulsar-Spark connector, we want to implement Admission Control for Pulsar as a streaming source. The user should be able to specify the maximum number of bytes that can be processed per microbatch. If we are under the threshold for the number of bytes for this microbatch, we will process the next ledger in this partition.
Describe the solution you'd like
Design Doc
Essentially, for each microbatch, we check the average number of bytes per ledger. If we have capacity left in this microbatch (ie. are under the threshold), then we will admit the next ledger
Describe alternatives you've considered
In the driver, we prefetch the ledgers and cache them, but this leads to both latency and memory overhead. Correctness issues can also arise with this solution