THIS IS A TEST INSTANCE. ALL YOUR CHANGES WILL BE LOST!!!!
...
| Page properties | ||||||||||||||||
|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|
Document the state by adding a label to the FLIP page with one of "discussion", "accepted", "released", "rejected".
|
Please keep the discussion on the mailing list rather than commenting on the wiki (wiki discussions get unwieldy fast).
...
Add the unassignedInitialPartitons(collection) and firstDiscoveryDone initialDiscoveryFinished(boolean) to the snapshot state. unassignedInitialPartitons represents the collection of first-discovered partitions that have not yet been assigned. firstDiscoveryDone represents whether the first-discovery has been done.
...
| Code Block | ||
|---|---|---|
| ||
public class KafkaSourceEnumState {
private final Set<TopicPartition> assignedPartitions;
private final Set<TopicPartition> unassignedInitialPartitons;
private final boolean firstDiscoveryDoneinitialDiscoveryFinished;
} |
Merge assignedPartitions and unassignedInitialPartitons collections
...