KPipe Core - Format-agnostic pipeline machinery for KPipe

KPipe Consumer - Functional Kafka consumer with virtual threads

KPipe Producer - Functional Kafka producer wrapper for KPipe

KPipe JSON format support — JsonFormat, JSON processors, and console sink

KPipe Avro format support — AvroFormat, Avro processors, and console sink

KPipe Protobuf format support — ProtobufFormat, processors, and console sink

Core Protocol Buffers library. Protocol Buffers are a way of encoding structured data in an

Avro is a row-oriented remote procedure call and data serialization framework that produces a compact binary format.

Kafka client library for building producers and consumers that interact with Apache Kafka clusters for high-throughput ...