kafka

package
v1.801.413 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Aug 4, 2026 License: Apache-2.0 Imports: 10 Imported by: 0

Documentation

Overview

Package kafka is Kafka on the platform bus: point a standard producer or consumer at :9092 and it works unchanged.

The Hanzo Kafka adaptor (github.com/hanzoai/kafka) speaks the Kafka binary protocol on :9092 and translates it to and from the JetStream apps/pubsub serves, so every client shares ONE bus. It connects to that PubSub as a NATS client on loopback :4222 — replacing the standalone `insights-kafka` Deployment. No ZooKeeper: the adaptor is stateless over JetStream (Lux consensus only).

It mounts NO HTTP routes of its own; cloud's generic per-subsystem liveness route answers /v1/kafka/health and the K8s Service TCP-probes :9092.

It ALWAYS serves, like the PubSub plane it rides (a staged cutover that is over). Mount fails CLOSED: a connect/bind error within the startup window aborts boot rather than serving a phantom broker. It dials the bus through pubsub.URL — the ONE knob every app in this process reads — so it cannot end up bridging a different bus than the one analytics publishes and webhooks consumes, and there is never a silent half-embed.

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func Mount

func Mount(app cloud.Router, deps cloud.Deps) error

Mount starts the embedded Kafka adaptor over the embedded JetStream.

func Shutdown

func Shutdown(_ context.Context) error

shutdown stops the embedded broker on graceful cloud shutdown. Idempotent.

Types

This section is empty.

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL