Uses of Class
com.hazelcast.jet.kafka.TopicsConfig.TopicConfig
-
Uses of TopicsConfig.TopicConfig in com.hazelcast.jet.kafka
Modifier and TypeMethodDescriptionTopicsConfig.TopicConfig.addPartitionInitialOffset
(int partition, long offset) Adds the initial offset for given partition to the configuration.TopicsConfig.getTopicConfig
(String topicName) Returns the topic configuration for given topic.Modifier and TypeMethodDescriptionTopicsConfig.getTopicConfigs()
Returns the map of topic configurations, mapped by topic name.Modifier and TypeMethodDescriptionTopicsConfig.addTopicConfig
(TopicsConfig.TopicConfig config) Adds the topic configuration.