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

Merge pull request #4 from medici/sasl_scram

Browse Source 
DE-121 - added env variable
This commit is contained in:
nitin kulkarni
2021-07-27 13:01:28 +05:30
committed by GitHub Enterprise
parent 2d8da1960c ada5858be0
commit 29ba0e9351
1 changed files with 2 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

4
producer/producer_config.go
View File

@@ -16,7 +16,7 @@ var (
asyncProducer sarama.AsyncProducer
)
func GetSyncProducerConfig(configuration config) *sarama.Config {
func GetSyncProducerConfig(configuration config.Configurations) *sarama.Config {
config := sarama.NewConfig()
kafkaConfiguration configuration.KafkaConfigurations
// security configs
@@ -44,7 +44,7 @@ func GetSyncProducerConfig(configuration config) *sarama.Config {
}
func GetAsyncProducerConfig(configuration config) *sarama.Config {
func GetAsyncProducerConfig(configuration config.Configurations) *sarama.Config {
config := sarama.NewConfig()
kafkaConfiguration configuration.KafkaConfigurations
// security configs