mirror of
https://github.com/hanzoai/stream.git
synced 2026-10-30 18:21:09 +00:00
zeekayandHanzo Dev
c3e231795c
This is the Kafka interface to Hanzo PubSub, not a product of its own. "Stream"
described the transport rather than the contract, and left two names for one
thing -- the repo was already redirecting hanzoai/kafka -> hanzoai/stream, so
imports and docs disagreed with the canonical URL.
The layering it belongs to:
hanzoai/tasks workloads and async workflows
|
hanzoai/pubsub the ONE event bus (JetStream-durable NATS)
|
hanzoai/kafka Kafka-wire adaptor (AMQP is the sibling seam)
|
hanzoai/datastore the ONE warehouse
Module path is now github.com/hanzoai/kafka; binary, image labels and docs say
Hanzo Kafka.
The word "stream" survives wherever it names the PROTOCOL rather than the
product -- JetStream stream names, ParseStreamName, the subject patterns in
pubsub/streams.go. Renaming those would have broken the wire contract to make a
brand consistent.
Unit tests pass. test/cluster and test/e2e still fail identically to before this
change: they shell out to an Apache Kafka distribution at ~/kafka_2.13-3.9.0/
that is not installed here, so they are unrelated to the rename.
Co-authored-by: Hanzo Dev <[email protected]>
23 lines
642 B
Go
23 lines
642 B
Go
package types
|
|
|
|
// Configuration represents the Hanzo Kafka broker configuration
|
|
type Configuration struct {
|
|
// Hanzo PubSub connection
|
|
PubSubUrl string // PubSub server URL (e.g. "nats://localhost:4222")
|
|
PubSubCredFile string // Optional PubSub credentials file
|
|
|
|
// Kafka listener
|
|
BrokerHost string `kafka:"CompactString"`
|
|
BrokerPort int
|
|
|
|
// Hanzo Kafka defaults
|
|
StreamReplicas int // Number of replicas for Hanzo Kafka (default 1)
|
|
StorageType string // "file" or "memory" (default "file")
|
|
|
|
// Admin HTTP server
|
|
AdminPort int // HTTP admin/monitoring port (default 9093, 0 to disable)
|
|
|
|
// Broker identity
|
|
NodeID int
|
|
}
|