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.