public static class TopicsConfig.TopicConfig extends Object implements Serializable
Constructor and Description |
---|
TopicConfig(String topicName)
Creates new topic configuration for given topic name.
|
Modifier and Type | Method and Description |
---|---|
TopicsConfig.TopicConfig |
addPartitionInitialOffset(int partition,
long offset)
Adds the initial offset for given partition to the configuration.
|
Long |
getPartitionInitialOffset(int partition)
Returns the initial offset for given partition or
null
if it was not defined. |
Map<Integer,Long> |
getPartitionsInitialOffsets()
Returns partitions initial offsets map.
|
String |
getTopicName()
Returns the name of the topic.
|
String |
toString() |
public String getTopicName()
public Map<Integer,Long> getPartitionsInitialOffsets()
@Nullable public Long getPartitionInitialOffset(int partition)
null
if it was not defined.public TopicsConfig.TopicConfig addPartitionInitialOffset(int partition, long offset)
partition
- the number of partitionoffset
- the initial offset for the partitionCopyright © 2023 Hazelcast, Inc.. All rights reserved.