Update kafka.go to fix typo and update config for external Kafka Conn…

…ection in SASL mode (#72) * Update kafka.go Signed-off-by: SahilDevgon <[email protected]> * Update kafka.go | remove comment Signed-off-by: SahilDevgon <[email protected]> * pkg/kafka.go:46 Code is expecting SecurityProtocol in config, fixing same in document Signed-off-by: SahilDevgon <[email protected]> * Resolve issue with case-sensitivity Signed-off-by: Sahil Devgon <[email protected]> --------- Signed-off-by: SahilDevgon <[email protected]> Signed-off-by: Sahil Devgon <[email protected]>
zilliztech · Jan 29, 2024 · 5af6827 · 5af6827
1 parent 5793bb9
commit 5af6827
Show file tree

Hide file tree

Showing 2 changed files with 3 additions and 3 deletions.
diff --git a/docs/administration/manage-dependencies/message-storage.md b/docs/administration/manage-dependencies/message-storage.md
@@ -238,8 +238,8 @@ metadata:
 spec:
   config:
     kafka:
-      # securityPolicy supports: PLAINTEXT, SSL, SASL_PLAINTEXT, SASL_SSL 
-      securityPolicy: PLAINTEXT
+      # securityProtocol supports: PLAINTEXT, SSL, SASL_PLAINTEXT, SASL_SSL 
+      securityProtocol: PLAINTEXT
       # saslMechanisms supports: PLAIN, SCRAM-SHA-256, SCRAM-SHA-512
       saslMechanisms: PLAIN
       saslUsername: ""

diff --git a/pkg/external/kafka.go b/pkg/external/kafka.go
@@ -108,7 +108,7 @@ func CheckKafka(conf CheckKafkaConfig) error {
 		ctx, cancel := context.WithTimeout(context.Background(), DependencyCheckTimeout)
 		defer cancel()
 		err := r.SetOffsetAt(ctx, time.Now())
-		return errors.Wrap(err, "check consume offset from borker failed")
+		return errors.Wrap(err, "check consume offset from broker failed")
 	}
 	return util.DoWithBackoff("checkKafka", checkKafka, util.DefaultMaxRetry, util.DefaultBackOffInterval)
 }