Package com.hazelcast.jet.kafka

Apache Kafka reader/writer support for Hazelcast Jet.

See: Description

Class Summary

Class	Description
KafkaDataConnection	DataConnection implementation for Kafka.
KafkaProcessors	Static utility class with factories of Apache Kafka source and sink processors.
KafkaSinks	Contains factory methods for Apache Kafka sinks.
KafkaSinks.Builder<E>	A builder for Kafka sink.
KafkaSources	Contains factory methods for Apache Kafka sources.
TopicsConfig	Contains the configuration for all Kafka topics that will be consumed by the Kafka source processor.
TopicsConfig.TopicConfig	Contains the configuration for a single Kafka topic.

Package com.hazelcast.jet.kafka Description

Apache Kafka reader/writer support for Hazelcast Jet.

Since:

Jet 3.0