From ada5858be0b5c8297d1aa350eaa2042200f3d180 Mon Sep 17 00:00:00 2001 From: Nitin Date: Tue, 27 Jul 2021 13:00:25 +0530 Subject: [PATCH] DE-121 - added env variable --- producer/producer_config.go | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/producer/producer_config.go b/producer/producer_config.go index c2f75e7..7d8a894 100644 --- a/producer/producer_config.go +++ b/producer/producer_config.go @@ -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