From b231d1b14e7d1592dd44390ebe083b55a2f6a157 Mon Sep 17 00:00:00 2001
From: doxsch <28098153+doxsch@users.noreply.github.com>
Date: Tue, 27 Jul 2021 09:16:40 +0200
Subject: [PATCH] Added ValidateOnly to CreatePartitionsRequest

---
 admin.go | 1 +
 1 file changed, 1 insertion(+)

diff --git a/admin.go b/admin.go
index abe18b19f..4187614f7 100644
--- 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 {