feat: enable retryconfiguration producer config

* feature/use-retry-brokers-for-retry-producer use retry brokers when producing to retry or error topics * feat: enable retryconfiguration broker add --------- Co-authored-by: erenarslan <[email protected]> Co-authored-by: Abdulsametileri <[email protected]>
Trendyol · May 30, 2024 · ed713be · ed713be
1 parent 6e542f1
commit ed713be
Show file tree

Hide file tree

Showing 3 changed files with 5 additions and 1 deletion.
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
@@ -3,7 +3,7 @@ module github.com/Trendyol/kafka-konsumer/v2
 go 1.19
 
 require (
-	github.com/Trendyol/kafka-cronsumer v1.5.1
+	github.com/Trendyol/kafka-cronsumer v1.5.2
 	github.com/Trendyol/otel-kafka-konsumer v0.0.7
 	github.com/ansrivas/fiberprometheus/v2 v2.6.1
 	github.com/gofiber/fiber/v2 v2.52.1

diff --git a/go.sum b/go.sum
@@ -2,6 +2,9 @@ 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/kafka-cronsumer v1.5.2 h1:wllvb2BhAWFnjN7wPVXVZ14lxPWAnLVlxKxoxIekQRI=
+github.com/Trendyol/kafka-cronsumer v1.5.2/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=