diff --git a/pkg/kafka/auth/options.go b/pkg/kafka/auth/options.go
index cc77a3f0464..40145ba3f92 100644
--- a/pkg/kafka/auth/options.go
+++ b/pkg/kafka/auth/options.go
@@ -106,7 +106,7 @@ func addTLSFlags(configPrefix string, flagSet *flag.FlagSet) {
 		"Path to the TLS Key for the Kafka connection")
 }
 
-func addPlainTextFlag(configPrefix string, flagSet *flag.FlagSet) {
+func addPlainTextFlags(configPrefix string, flagSet *flag.FlagSet) {
 	flagSet.String(
 		configPrefix+plainTextPrefix+suffixPlainTextUserName,
 		defaultPlainTextUserName,
@@ -126,5 +126,5 @@ func AddFlags(configPrefix string, flagSet *flag.FlagSet) {
 	)
 	addKerberosFlags(configPrefix, flagSet)
 	addTLSFlags(configPrefix, flagSet)
-	addPlainTextFlag(configPrefix, flagSet)
+	addPlainTextFlags(configPrefix, flagSet)
 }