com.hazelcast.jet.kafka

Class TopicsConfig

java.lang.Object

com.hazelcast.jet.kafka.TopicsConfig

All Implemented Interfaces:

Serializable

public class TopicsConfig
extends Object
implements Serializable

Contains the configuration for all Kafka topics that will be consumed by the Kafka source processor.

Since:

5.3

See Also:

Serialized Form

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	TopicsConfig.TopicConfig Contains the configuration for a single Kafka topic.

Constructor Summary

Constructors

Constructor and Description
TopicsConfig()

Method Summary

Modifier and Type	Method and Description
TopicsConfig	addTopic(String topicName) Creates empty topic configuration and saves it in the map under the topic name.
TopicsConfig	addTopicConfig(TopicsConfig.TopicConfig config) Adds the topic configuration.
TopicsConfig	addTopics(List<String> topicNames) Creates new topic configurations for every provided topic from the list and saves them in the map.
Long	getInitialOffsetFor(String topicName, int partition) Returns initial offset value for the given topic and partition combination.
TopicsConfig.TopicConfig	getTopicConfig(String topicName) Returns the topic configuration for given topic.
Map<String,TopicsConfig.TopicConfig>	getTopicConfigs() Returns the map of topic configurations, mapped by topic name.
Set<String>	getTopicNames() Returns the set of topic names from topic configurations.
String	toString()

Methods inherited from class java.lang.Object

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

Constructor Detail

TopicsConfig

public TopicsConfig()

Method Detail

getTopicConfigs

public Map<String,TopicsConfig.TopicConfig> getTopicConfigs()

Returns the map of topic configurations, mapped by topic name.

getTopicNames

public Set<String> getTopicNames()

Returns the set of topic names from topic configurations. Returned set of topic names is guaranteed to preserve the order of insertion of topic configurations that were added via addTopicConfig(TopicConfig) or addTopic(String)

getTopicConfig

@Nullable
public TopicsConfig.TopicConfig getTopicConfig(String topicName)

Returns the topic configuration for given topic.

addTopicConfig

public TopicsConfig addTopicConfig(TopicsConfig.TopicConfig config)

Adds the topic configuration. The configuration is saved under the topic name.

addTopic

public TopicsConfig addTopic(String topicName)

Creates empty topic configuration and saves it in the map under the topic name.

addTopics

public TopicsConfig addTopics(List<String> topicNames)

Creates new topic configurations for every provided topic from the list and saves them in the map.

getInitialOffsetFor

@Nullable
public Long getInitialOffsetFor(String topicName,
                                          int partition)

Returns initial offset value for the given topic and partition combination. If configuration for specified topic does not exist, or if initial offset is not defined for the given partition then null is returned.

toString

public String toString()

Overrides:

toString in class Object