Group: GitHub Eschizoid

Sort by:Popular▼

✓Popular✓Newest

KPipe Core - Format-agnostic pipeline machinery for KPipe

KPipe Tracing - vendor-neutral Tracer SPI for cross-Kafka-boundary trace propagation (no-op default)

Public DSL surface of telescope — deep-copy DSL for Java records and POJOs.

Telescope — a deep-copy DSL for Java records and POJOs.

KPipe Producer - Functional Kafka producer wrapper for KPipe

Internal substrate of the telescope optics DSL: optic lattice (Iso/Lens/Prism/Affine/Traversal), HKT-emulation (Kind/Applicative), per-effect witnesses, and reflection helpers. Qualified-exported to telescope-core only — do NOT depend on this ...

KPipe Consumer - Functional Kafka consumer with virtual threads

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

KPipe Metrics - telemetry interfaces for KPipe (no-op default; bring your own backend)

Deep-copy DSL for Java records and POJOs.

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

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

Compile-time codegen for telescope — @Focus / @BeanFocus / @Bridge annotation processors that emit typed <X>Telescope navigators for reflection-free deep navigation.

KPipe BOM — Maven Bill-of-Materials that pins all kpipe-* modules to matching versions

KPipe API — fluent top-level KPipe entry point for the common consumer path

KPipe Protobuf Confluent Schema Registry support — ConfluentProtobufDescriptorCompiler (runtime .proto compilation via Confluent ProtobufSchema)

KPipe Metrics OTel - OpenTelemetry-backed implementation of kpipe-metrics interfaces

KPipe Schema Registry Confluent - Confluent Schema Registry client (schema-by-ID lookup, JSON envelope unwrap)

KPipe test kit — TestStream driver and CapturingSink for Docker-free pipeline unit tests

KPipe Tracing OTel - OpenTelemetry-backed implementation of the kpipe Tracer SPI