diff options
Diffstat (limited to 'weed/mq/client/cmd/weed_pub/publisher.go')
| -rw-r--r-- | weed/mq/client/cmd/weed_pub/publisher.go | 1 |
1 files changed, 1 insertions, 0 deletions
diff --git a/weed/mq/client/cmd/weed_pub/publisher.go b/weed/mq/client/cmd/weed_pub/publisher.go index ee00be9f8..d1f2e7c90 100644 --- a/weed/mq/client/cmd/weed_pub/publisher.go +++ b/weed/mq/client/cmd/weed_pub/publisher.go @@ -36,6 +36,7 @@ func main() { flag.Parse() config := &pub_client.PublisherConfiguration{ CreateTopic: true, + CreateTopicPartitionCount: 1, } publisher := pub_client.NewTopicPublisher(*namespace, *topic, config) brokers := strings.Split(*seedBrokers, ",") |