Skip to content

Commit

Permalink
rm unnecessary comments
Browse files Browse the repository at this point in the history
  • Loading branch information
mikekosulin committed Oct 30, 2024
1 parent 7cb11d1 commit 0ea377e
Showing 1 changed file with 0 additions and 2 deletions.
2 changes: 0 additions & 2 deletions builtin/bins/dkron-executor-kafka/kafka.go
Original file line number Diff line number Diff line change
Expand Up @@ -84,13 +84,11 @@ func (s *Kafka) ExecuteImpl(args *dktypes.ExecuteRequest) ([]byte, error) {
config.Net.SASL.Handshake = true

if args.Config["saslMechanism"] == "sha512" {
log.Println("Using SCRAM SHA-512 for SASL authentication")
config.Net.SASL.SCRAMClientGeneratorFunc = func() sarama.SCRAMClient {
return &XDGSCRAMClient{HashGeneratorFcn: SHA512}
}
config.Net.SASL.Mechanism = sarama.SASLTypeSCRAMSHA512
} else if args.Config["saslMechanism"] == "sha256" {
log.Println("Using SCRAM SHA-256 for SASL authentication")
config.Net.SASL.SCRAMClientGeneratorFunc = func() sarama.SCRAMClient {
return &XDGSCRAMClient{HashGeneratorFcn: SHA256}
}
Expand Down

0 comments on commit 0ea377e

Please sign in to comment.