Package com.hazelcast.jet.kafka

Apache Kafka reader/writer support for Hazelcast Jet.

Since:

Jet 3.0

Class Summary

Class	Description
HazelcastKafkaAvroDeserializer	An Avro deserializer for Kafka.
HazelcastKafkaAvroSerializer	An Avro serializer for Kafka.
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.