kafka

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.