varnitgoyal95/janus
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

Merge pull request #8 from medici/sasl_scram

Browse Source 
DE-121 - added scram
This commit is contained in:
nitin kulkarni
2021-07-27 15:26:25 +05:30
committed by GitHub Enterprise
parent 8ae947823d 9de329de4c
commit e59fada191
1 changed files with 8 additions and 8 deletions
Download Patch File Download Diff File Expand all files Collapse all files

16
producer/producer_config.go
View File

@@ -24,10 +24,10 @@ func GetSyncProducerConfig(kafkaConfiguration config.KafkaConfigurations, env st
if env == "PROD" {
config.Net.SASL.Enable = true
config.Net.SASL.Handshake = true
config.Net.SASL.Mechanism = sarama.SASLMechanism(sarama.SASLTypeSCRAMSHA512)
config.Net.SASL.SCRAMClientGeneratorFunc = func() sarama.SCRAMClient {
return &scramclient.XDGSCRAMClient{HashGeneratorFcn: scramclient.SHA512}
}
config.Net.SASL.Mechanism = sarama.SASLTypeSCRAMSHA512
/* saramaConfig.Net.SASL.SCRAMClientGeneratorFunc = func() sarama.SCRAMClient {
return &XDGSCRAMClient{HashGeneratorFcn: SHA512}
} */
config.Net.SASL.User = kafkaConfiguration.Sasl_User
config.Net.SASL.Password = kafkaConfiguration.Sasl_Password
}
@@ -55,10 +55,10 @@ func GetAsyncProducerConfig(kafkaConfiguration config.KafkaConfigurations, env s
if env == "PROD" {
config.Net.SASL.Enable = true
config.Net.SASL.Handshake = true
config.Net.SASL.Mechanism = sarama.SASLMechanism(sarama.SASLTypeSCRAMSHA512)
config.Net.SASL.SCRAMClientGeneratorFunc = func() sarama.SCRAMClient {
return &scramclient.XDGSCRAMClient{HashGeneratorFcn: scramclient.SHA512}
}
config.Net.SASL.Mechanism = sarama.SASLMechanism(sarama.SASLTypeSCRAMSHA512)
/*config.Net.SASL.SCRAMClientGeneratorFunc = func() sarama.SCRAMClient {
return &scramclient.XDGSCRAMClient{HashGeneratorFcn: scramClient.SHA512}
} */
config.Net.SASL.User = kafkaConfiguration.Sasl_User
config.Net.SASL.Password = kafkaConfiguration.Sasl_Password
}