From 3ed9a9d3d03e6649c766bcfd10e15466277dc9c5 Mon Sep 17 00:00:00 2001
From: Abdulsametileri <sametileri07@gmail.com>
Date: Tue, 25 Apr 2023 17:23:32 +0300
Subject: [PATCH] feat: pass rack configuration to kafka-cronsumer

---
 .gitignore  | 2 +-
 consumer.go | 1 +
 2 files changed, 2 insertions(+), 1 deletion(-)

diff --git a/.gitignore b/.gitignore
index 64ebb9b..f3f260a 100644
--- a/.gitignore
+++ b/.gitignore
@@ -1,2 +1,2 @@
 .idea
-.dist/
\ No newline at end of file
+dist/
\ No newline at end of file
diff --git a/consumer.go b/consumer.go
index 581b5e8..9c8d351 100644
--- 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() {