kafka

Overview ¶

Package kafka embeds the Hanzo Stream Kafka-wire adaptor (github.com/hanzoai/ stream) as an in-process cloud subsystem (HIP-0106), translating the Kafka protocol to/from the embedded JetStream (clients/pubsub). When enabled it binds the Kafka listener (default :9092) and connects, as a NATS client, to the in-process PubSub 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 embedded PubSub by default — CLOUD_KAFKA_PUBSUB_URL points it at an external one instead — so there is never a silent half-embed.