feat: pass rack configuration to kafka-cronsumer

Abdulsametileri · Abdulsametileri · commit 3ed9a9d3d03e · 2023-04-25T17:23:32.000+03:00
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 number	Diff line change
`@@ -84,6 +84,7 @@ func NewConsumer(cfg *ConsumerConfig) (Consumer, error) {`
`84`	`84`	`kcronsumerCfg.SASL.AuthType = string(cfg.SASL.Type)`
`85`	`85`	`kcronsumerCfg.SASL.Username = cfg.SASL.Username`
`86`	`86`	`kcronsumerCfg.SASL.Password = cfg.SASL.Password`
	`87`	`+ kcronsumerCfg.SASL.Rack = cfg.Rack`
`87`	`88`	`}`
`88`	`89`
`89`	`90`	`if !cfg.TLS.IsEmpty() {`