[Draft] KafkaIO SDF: Fetch end position for each topic-partition tuple in a background thread, reusing kafka consumers. #32459
Job | Run time |
---|---|
18s | |
4m 12s | |
4m 56s | |
2m 5s | |
2m 44s | |
2m 38s | |
5m 35s | |
0s | |
22m 28s |
Job | Run time |
---|---|
18s | |
4m 12s | |
4m 56s | |
2m 5s | |
2m 44s | |
2m 38s | |
5m 35s | |
0s | |
22m 28s |