feature/use-retry-brokers-for-retry-producer use retry brokers when p…

…roducing to retry or error topics
Trendyol · May 29, 2024 · 7718880 · 7718880
1 parent 6e542f1
commit 7718880
Show file tree

Hide file tree

Showing 3 changed files with 4 additions and 0 deletions.
diff --git 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
@@ -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
@@ -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=