Namespace Pipelinez.Kafka.Source Classes KafkaPipelineSource<T, TRecordKey, TRecordValue> Consumes records from Kafka and publishes them into a Pipelinez pipeline.