Namespace Pipelinez.Kafka.Destination

Classes

KafkaDeadLetterDestination<T, TRecordKey, TRecordValue>

Writes Pipelinez dead-letter records to a Kafka topic.

KafkaPipelineDestination<T, TRecordKey, TRecordValue>

Publishes pipeline records to a Kafka topic.