Uses of Class
com.hazelcast.jet.kafka.TopicsConfig
-
Uses of TopicsConfig in com.hazelcast.jet.kafka
Modifier and TypeMethodDescriptionCreates empty topic configuration and saves it in the map under the topic name.TopicsConfig.addTopicConfig
(TopicsConfig.TopicConfig config) Adds the topic configuration.Creates new topic configurations for every provided topic from the list and saves them in the map.Modifier and TypeMethodDescriptionstatic <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 asMap.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 forKafkaSources.kafka(Properties, FunctionEx, TopicsConfig)
}.