diff options
| author | chrislu <chris.lu@gmail.com> | 2024-05-02 08:35:06 -0700 |
|---|---|---|
| committer | chrislu <chris.lu@gmail.com> | 2024-05-02 08:35:06 -0700 |
| commit | 928a4e8dff01bab01766ca761f3bc56862a20736 (patch) | |
| tree | e3c6b374ade65f0213385fb1538f10630d0a66d8 | |
| parent | 5bc1b70a4c7a0acc3fa182f90ddef4212b094d33 (diff) | |
| download | seaweedfs-928a4e8dff01bab01766ca761f3bc56862a20736.tar.xz seaweedfs-928a4e8dff01bab01766ca761f3bc56862a20736.zip | |
rename
| -rw-r--r-- | .gitignore | 2 | ||||
| -rw-r--r-- | weed/mq/client/cmd/weed_pub_kv/publisher_kv.go (renamed from weed/mq/client/cmd/weed_pub/publisher.go) | 1 |
2 files changed, 2 insertions, 1 deletions
diff --git a/.gitignore b/.gitignore index 2a858c427..c3cb0386a 100644 --- a/.gitignore +++ b/.gitignore @@ -87,7 +87,7 @@ other/java/hdfs/dependency-reduced-pom.xml # binary file weed/weed -weed/mq/client/cmd/weed_pub/weed_pub +weed/mq/client/cmd/weed_pub_kv/weed_pub docker/weed # test generated files diff --git a/weed/mq/client/cmd/weed_pub/publisher.go b/weed/mq/client/cmd/weed_pub_kv/publisher_kv.go index 482e28384..59842c21f 100644 --- a/weed/mq/client/cmd/weed_pub/publisher.go +++ b/weed/mq/client/cmd/weed_pub_kv/publisher_kv.go @@ -45,6 +45,7 @@ func doPublish(publisher *pub_client.TopicPublisher, id int) { func main() { flag.Parse() + config := &pub_client.PublisherConfiguration{ Topic: topic.NewTopic(*namespace, *t), PartitionCount: int32(*partitionCount), |