Page History

...

1. Read from multiple clusters, topics, and partitions.
2. Assign splits from multiple clusters.
3. Checkpoint splits and commit split progress from multiple clusters.
4. Report Kafka source metrics for multiple clusters.
5. Communicate metadata changes via source events from enumerator to readers.
6. Cleanup resources (e.g. clients, thread pools, metrics) related to old clusters.

...