SourceTestUtils has a fair bit of support for testing things like dynamic work rebalancing and initial splitting.
We should add variants that test UnboundedSource checkpoint-and-resume, etc.
Imported from Jira BEAM-74. Original Jira may contain additional context.
Reported by: dhalperi.