diff --git a/consumer_config.go b/consumer_config.go index 3610f6b..6fb88b5 100644 --- a/consumer_config.go +++ b/consumer_config.go @@ -86,6 +86,7 @@ func (cfg *ConsumerConfig) newCronsumerConfig() *kcronsumer.Config { }, Producer: kcronsumer.ProducerConfig{ Balancer: cfg.RetryConfiguration.Balancer, + Brokers: cfg.RetryConfiguration.Brokers, }, LogLevel: lcronsumer.Level(cfg.RetryConfiguration.LogLevel), } diff --git a/go.mod b/go.mod index ba73591..7113d85 100644 --- a/go.mod +++ b/go.mod @@ -2,6 +2,8 @@ module github.com/Trendyol/kafka-konsumer/v2 go 1.19 +replace github.com/Trendyol/kafka-cronsumer v1.5.1 => github.com/Trendyol/kafka-cronsumer v1.5.2-0.20240529192345-3622137cb12a + require ( github.com/Trendyol/kafka-cronsumer v1.5.1 github.com/Trendyol/otel-kafka-konsumer v0.0.7 diff --git a/go.sum b/go.sum index 95a2f10..53f273c 100644 --- a/go.sum +++ b/go.sum @@ -2,6 +2,7 @@ github.com/Trendyol/kafka-cronsumer v1.5.0 h1:MI0/ncHrlCvOV0Ro4h9avm2izsNprBw4Qf github.com/Trendyol/kafka-cronsumer v1.5.0/go.mod h1:VpweJmKY+6dppFhzWOZDbZfxBNuJkSxB12CcuZWBNFU= github.com/Trendyol/kafka-cronsumer v1.5.1 h1:L8RLxo8zSGOfVpjtXLUqL3PsJLZdeoFcOvN1yCY/GyQ= github.com/Trendyol/kafka-cronsumer v1.5.1/go.mod h1:VpweJmKY+6dppFhzWOZDbZfxBNuJkSxB12CcuZWBNFU= +github.com/Trendyol/kafka-cronsumer v1.5.2-0.20240529192345-3622137cb12a/go.mod h1:VpweJmKY+6dppFhzWOZDbZfxBNuJkSxB12CcuZWBNFU= github.com/Trendyol/otel-kafka-konsumer v0.0.7 h1:sT1TE2rgfsdrJWrXKz5j6dPkKJsvP+Tv0Dea4ORqJ+4= github.com/Trendyol/otel-kafka-konsumer v0.0.7/go.mod h1:zdCaFclzRCO9fzcjxkHrWOB3I2+uTPrmkq4zczkD1F0= github.com/andybalholm/brotli v1.0.5 h1:8uQZIdzKmjc/iuPu7O2ioW48L81FgatrcpfFmiq/cCs=