Package com.hazelcast.jet.kafka

package com.hazelcast.jet.kafka

Apache Kafka reader/writer support for Hazelcast Jet.

Since:

Jet 3.0

Related Packages

Package	Description
com.hazelcast.jet	Hazelcast Jet is a distributed computation engine running on top of Hazelcast IMDG technology.
com.hazelcast.jet.kafka.connect	Contains a generic Kafka Connect source provides ability to plug any Kafka Connect source for data ingestion to Jet pipelines.

Classes

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.