Event Pipeline

The event pipeline moves kernel events from recorder agents to storage and analysis services.

Responsibilities

The pipeline must:

  • accept high-volume event streams
  • buffer during downstream pressure
  • validate event shape
  • preserve ordering where possible
  • route invalid events to a dead-letter path
  • make event delivery observable

Topics

A typical deployment uses:

StreamPurpose
kernel.rawEvents directly from recorder agents.
kernel.enrichedValidated events with normalized fields.
otel.spansTrace spans used for correlation.
kernel.dlqInvalid or unparseable events.

Why buffering matters

During an incident, event volume can spike exactly when downstream systems are under pressure. The pipeline protects kprobe from losing the most important data at the worst time.

Verification

Operators should be able to answer:

  • Are agents publishing events?
  • Is the pipeline accepting them?
  • Is enrichment keeping up?
  • Are events reaching storage?
  • Are any events being dropped or sent to the DLQ?