Hanzo Stream
Kafka clients, JetStream durability
Use standard Kafka producers and consumers with NATS JetStream as the backend. No ZooKeeper, no broker management, no JVM tuning. Just durable event streaming.
Kafka Without the Pain
Keep your Kafka clients. Drop the operational burden.
Kafka Compatible
Standard Kafka wire protocol. Use kafka-python, sarama, confluent-kafka, or any Kafka client library.
JetStream Backend
NATS JetStream provides durable, replicated storage with at-least-once delivery guarantees.
Zero JVM
No Java, no ZooKeeper, no broker tuning. Single Go binary with minimal resource usage.
Consumer Groups
Full consumer group support with automatic partition rebalancing and offset management.
Topic Management
Create, list, and delete topics via Kafka admin API. Retention policies and compaction.
TLS & Auth
SASL/PLAIN and SASL/SCRAM authentication. TLS encryption in transit. ACL support.
Drop-In Kafka Replacement
from kafka import KafkaProducer, KafkaConsumer
# Just change the bootstrap server
producer = KafkaProducer(
bootstrap_servers=["stream.hanzo.ai:9092"],
value_serializer=lambda v: json.dumps(v).encode(),
)
producer.send("events", {"type": "user.signup", "user_id": "usr_123"})
# Consumer groups work identically
consumer = KafkaConsumer(
"events",
bootstrap_servers=["stream.hanzo.ai:9092"],
group_id="my-service",
auto_offset_reset="earliest",
)
for message in consumer:
process(message.value)25% of compute goes back to open source
Every deployment is SBOM-verified. Contributors to franz-go earn a share of compute revenue — transparent, on-chain, and customizable by the community.
25% of compute goes back to OSS authors
Every Hanzo deployment tracks software dependencies via SBOM. When your code powers compute on Hanzo, the authors get paid — automatically.
Stream Events at Scale
Migrate from Kafka in minutes. Keep your existing code.