public class FullRangeGenerator extends Object implements RangeGenerator
SubscriptionType.Shared
, SubscriptionType.Failover
and
SubscriptionType.Exclusive
subscription.Constructor and Description |
---|
FullRangeGenerator() |
Modifier and Type | Method and Description |
---|---|
List<TopicRange> |
range(TopicMetadata metadata,
int parallelism)
Generate range for the given topic.
|
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
open
public List<TopicRange> range(TopicMetadata metadata, int parallelism)
RangeGenerator
range
in interface RangeGenerator
metadata
- The metadata of the topic.parallelism
- The reader size for this topic.Copyright © 2014–2023 The Apache Software Foundation. All rights reserved.