public class PulsarSourceEnumState extends Object
SplitAssigner
.Constructor and Description |
---|
PulsarSourceEnumState(Set<TopicPartition> appendedPartitions) |
Modifier and Type | Method and Description |
---|---|
Set<TopicPartition> |
getAppendedPartitions() |
static PulsarSourceEnumState |
initialState()
The initial assignment state for Pulsar.
|
public PulsarSourceEnumState(Set<TopicPartition> appendedPartitions)
public Set<TopicPartition> getAppendedPartitions()
public static PulsarSourceEnumState initialState()
Copyright © 2014–2024 The Apache Software Foundation. All rights reserved.