| Package | Description | 
|---|---|
| com.hazelcast.jet.kafka | 
 Apache Kafka reader/writer support for Hazelcast Jet. 
 | 
| Modifier and Type | Method and Description | 
|---|---|
TopicsConfig.TopicConfig | 
TopicsConfig.TopicConfig.addPartitionInitialOffset(int partition,
                         long offset)
Adds the initial offset for given partition to the configuration. 
 | 
TopicsConfig.TopicConfig | 
TopicsConfig.getTopicConfig(String topicName)
Returns the topic configuration for given
 topic. 
 | 
| Modifier and Type | Method and Description | 
|---|---|
Map<String,TopicsConfig.TopicConfig> | 
TopicsConfig.getTopicConfigs()
Returns the map of topic configurations,
 mapped by topic name. 
 | 
| Modifier and Type | Method and Description | 
|---|---|
TopicsConfig | 
TopicsConfig.addTopicConfig(TopicsConfig.TopicConfig config)
Adds the topic configuration. 
 | 
Copyright © 2023 Hazelcast, Inc.. All rights reserved.