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