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.