com.northconcepts.datapipeline.kafka (Data Pipeline JavaDoc)

package com.northconcepts.datapipeline.kafka

Read and write Apache Kafka distributed messaging system data.

Classes

Class

Description

KafkaReader

Read Records from an Apache Kafka distributed messaging system.

KafkaWriter

Write Records to an Apache Kafka distributed messaging system.

RecordDeserializer

Kafka value deserializer that rebuilds a Record from its binary form; used by KafkaReader.

RecordSerializer

Kafka value serializer that writes a Record in its binary form; used by KafkaWriter.