Fix the config
diff --git a/examples/orderproducer/producer.go b/examples/orderproducer/producer.go
index 8e78fb9..f8cc402 100644
--- a/examples/orderproducer/producer.go
+++ b/examples/orderproducer/producer.go
@@ -48,6 +48,8 @@
}
}
+// example:
+// ./producer -n "localhost:9988" -t local_test -g local_test -d data -m 100 -w 10
func main() {
flag.Parse()
@@ -82,8 +84,8 @@
}
producer := rocketmq.NewProduer(&rocketmq.ProducerConfig{
- GroupID: "testGroup",
- NameServer: "10.200.20.25:9988",
+ GroupID: groupID,
+ NameServer: namesrvAddrs,
})
producer.Start()
defer producer.Shutdown()