What it is
Operational data movement where the runtime owns the hard parts.
StreamKernel is built for pipelines where policy, in-process enrichment, DLQ routing, metrics, provenance, and multi-destination delivery need to be controlled together.
Product
A source-available JVM pipeline runtime for policy, enrichment, delivery, and evidence.
StreamKernel sits between event transport and operational or analytical destinations, giving teams one runtime boundary for governed movement instead of scattered glue code.
What it is not
Not another Kafka client, smaller Spark, connector framework, or model-serving wrapper.
The product category is an auditable pipeline boundary for operational movement, not a replacement for transport, analytics engines, or standalone model serving.
Core capabilities
One runtime surface for the pieces that usually become custom infrastructure.
Source pluginsPolicy pluginsTransformer chainsONNX/DJL enrichmentMLflow registry integrationCache-aware processingSink pluginsPostgres sinksPostgres Vector sinksDLQ routingPrometheus metrics exportOpenTelemetry exportmTLS + OPA policy pathBenchmark runnerProvenance and audit headersCommercial plugin/IP boundary
Runtime boundary
One JVM. One pipeline config. One benchmark envelope.
StreamKernel collapses the operational glue around event movement, AI enrichment, policy, delivery, and evidence into a single runtime.
Governed movement
Policy and audit behavior stay attached to the pipeline, not buried in one-off services.
Commercial AI path
Protected AI implementation, production packaging, redistribution, support, and negotiated rights live behind direct engagement.
Benchmarkable operations
Runtime evidence includes benchmark matrices, effective settings, logs, GC output, Prometheus/OpenTelemetry metrics, replay metadata, and a 366K ops/sec mTLS + OPA baseline for regulated paths.
Commercial path
Built for teams tired of turning glue code into infrastructure.
Bring a streaming, AI enrichment, OEM, or regulated delivery scenario and review the runtime path with StreamKernel.