Added ValidateOnly to CreatePartitionsRequest

IBM · Jul 27, 2021 · b231d1b · b231d1b
1 parent 70416ae
commit b231d1b
Showing 1 changed file with 1 addition and 0 deletions.
diff --git a/admin.go b/admin.go
@@ -443,6 +443,7 @@ func (ca *clusterAdmin) CreatePartitions(topic string, count int32, assignment [
 	request := &CreatePartitionsRequest{
 		TopicPartitions: topicPartitions,
 		Timeout:         ca.conf.Admin.Timeout,
+		ValidateOnly:    validateOnly,
 	}
 
 	return ca.retryOnError(isErrNoController, func() error {