feat: pass rack configuration to kafka-cronsumer

Trendyol · Apr 25, 2023 · 3ed9a9d · 3ed9a9d
1 parent a4fac27
commit 3ed9a9d
Show file tree

Hide file tree

Showing 2 changed files with 2 additions and 1 deletion.
diff --git a/.gitignore b/.gitignore
@@ -1,2 +1,2 @@
 .idea
-.dist/
+dist/
diff --git a/consumer.go b/consumer.go
@@ -84,6 +84,7 @@ func NewConsumer(cfg *ConsumerConfig) (Consumer, error) {
 			kcronsumerCfg.SASL.AuthType = string(cfg.SASL.Type)
 			kcronsumerCfg.SASL.Username = cfg.SASL.Username
 			kcronsumerCfg.SASL.Password = cfg.SASL.Password
+			kcronsumerCfg.SASL.Rack = cfg.Rack
 		}
 
 		if !cfg.TLS.IsEmpty() {
-Original file line number
+Diff line change
@@ -1,2 +1,2 @@
     .idea
-    .dist/
+    dist/