Skip to content

[GOBBLIN-1922]Add function in Kafka Source to recompute workUnits for filtered partitions #2541

[GOBBLIN-1922]Add function in Kafka Source to recompute workUnits for filtered partitions

[GOBBLIN-1922]Add function in Kafka Source to recompute workUnits for filtered partitions #2541