Package | Description |
---|---|
com.hazelcast.jet.kafka |
Apache Kafka reader/writer support for Hazelcast Jet.
|
Modifier and Type | Method and Description |
---|---|
TopicsConfig |
TopicsConfig.addTopic(String topicName)
Creates empty topic configuration and saves it
in the map under the topic name.
|
TopicsConfig |
TopicsConfig.addTopicConfig(TopicsConfig.TopicConfig config)
Adds the topic configuration.
|
TopicsConfig |
TopicsConfig.addTopics(List<String> topicNames)
Creates new topic configurations for every
provided topic from the list and saves them in the map.
|
Modifier and Type | Method and Description |
---|---|
static <K,V,T> StreamSource<T> |
KafkaSources.kafka(Properties properties,
FunctionEx<org.apache.kafka.clients.consumer.ConsumerRecord<K,V>,T> projectionFn,
TopicsConfig topicsConfig)
Returns a source that consumes one or more Apache Kafka topics and emits
items from them as
Map.Entry instances. |
static <K,V,T> ProcessorMetaSupplier |
KafkaProcessors.streamKafkaP(Properties properties,
FunctionEx<? super org.apache.kafka.clients.consumer.ConsumerRecord<K,V>,? extends T> projectionFn,
EventTimePolicy<? super T> eventTimePolicy,
TopicsConfig topicsConfig)
Returns a supplier of processors for
KafkaSources.kafka(Properties, FunctionEx, TopicsConfig) }. |
Copyright © 2023 Hazelcast, Inc.. All rights reserved.