Uses of Class
com.hazelcast.jet.kafka.TopicsConfig

Packages that use TopicsConfig

Package	Description
com.hazelcast.jet.kafka	Apache Kafka reader/writer support for Hazelcast Jet.

Uses of TopicsConfig in com.hazelcast.jet.kafka

Methods in com.hazelcast.jet.kafka that return TopicsConfig

Modifier and Type	Method	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.

Methods in com.hazelcast.jet.kafka with parameters of type TopicsConfig

Modifier and Type	Method	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)}.