diff options
| -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), |