Package com.hazelcast.jet.kafka

Class TopicsConfig.TopicConfig

java.lang.Object

com.hazelcast.jet.kafka.TopicsConfig.TopicConfig

All Implemented Interfaces:

Serializable

Enclosing class:

TopicsConfig

public static class TopicsConfig.TopicConfig
extends Object
implements Serializable

Contains the configuration for a single Kafka topic.

See Also:

• Serialized Form

Constructor Summary

Constructors

Constructor	Description
TopicConfig(String topicName)	Creates new topic configuration for given topic name.

Method Summary

Modifier and Type	Method	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()

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait

Constructor Details

TopicConfig

public TopicConfig(@Nonnull
 String topicName)

Creates new topic configuration for given topic name.

Method Details

getTopicName

public String getTopicName()

Returns the name of the topic.

getPartitionsInitialOffsets

public Map<Integer,Long> getPartitionsInitialOffsets()

Returns partitions initial offsets map.

getPartitionInitialOffset

@Nullable
public Long getPartitionInitialOffset(int partition)

Returns the initial offset for given partition or null if it was not defined.

addPartitionInitialOffset

public TopicsConfig.TopicConfig addPartitionInitialOffset(int partition,
 long offset)

Adds the initial offset for given partition to the configuration.

Parameters:

partition - the number of partition

offset - the initial offset for the partition

toString

public String toString()

Overrides:

toString in class Object