THIS IS A TEST INSTANCE. ALL YOUR CHANGES WILL BE LOST!!!!
...
KafkaSourceEnumerator
Add variable attributes newDiscoveryOffsetsInitializer、 attributes unassignedInitialPartitons and initialPartitionDone to KafkaSourceEnumerator, which will be explained in the Proposed Changes section.
...