From 3fa024479e136e01ca5ebf0bfccd3ba74c424916 Mon Sep 17 00:00:00 2001 From: chrislu Date: Fri, 12 Sep 2025 23:04:41 -0700 Subject: [PATCH] remove TestMode --- weed/mq/kafka/gateway/server.go | 11 +++++------ 1 file changed, 5 insertions(+), 6 deletions(-) diff --git a/weed/mq/kafka/gateway/server.go b/weed/mq/kafka/gateway/server.go index a839081f8..9326dd1ce 100644 --- a/weed/mq/kafka/gateway/server.go +++ b/weed/mq/kafka/gateway/server.go @@ -49,9 +49,8 @@ func resolveAdvertisedAddress() string { type Options struct { Listen string - Masters string // SeaweedFS master servers (required for production mode) + Masters string // SeaweedFS master servers (required for production mode, empty for testing) FilerGroup string // filer group name (optional) - TestMode bool // Use in-memory handler for testing (optional) } type Server struct { @@ -69,12 +68,12 @@ func NewServer(opts Options) *Server { var handler *protocol.Handler var err error - if opts.TestMode || opts.Masters == "" { - // Use in-memory handler for testing or when no masters are configured + if opts.Masters == "" { + // Use in-memory handler when no masters are configured (typical for tests) handler = protocol.NewHandler() - glog.V(1).Infof("Created Kafka gateway with in-memory handler for testing") + glog.V(1).Infof("Created Kafka gateway with in-memory handler") } else { - // Create broker-based SeaweedMQ handler for production + // Create broker-based SeaweedMQ handler when masters are provided handler, err = protocol.NewSeaweedMQBrokerHandler(opts.Masters, opts.FilerGroup) if err != nil { glog.Fatalf("Failed to create SeaweedMQ broker handler: %v", err)