Interface | Description |
---|---|
RangeGenerator |
A generator for generating the
TopicRange for given topic. |
Class | Description |
---|---|
FixedRangeGenerator |
Always return the same range set for all topics.
|
FullRangeGenerator |
Default implementation for
SubscriptionType.Shared , SubscriptionType.Failover and
SubscriptionType.Exclusive subscription. |
UniformRangeGenerator |
This range generator would divide the range by the flink source parallelism.
|
Copyright © 2014–2023 The Apache Software Foundation. All rights reserved.