Merge #7

7: Fix typo in env-var: KAFKA_LOG_CONSUMER_GROUP r=Jaskaranbir a=Jaskaranbir



Co-authored-by: Jaskaranbir <jaskaranbir.dhillon@gmail.com>

Author: ninja-bruh

.env

@@ -1,3 +1,3 @@
 KAFKA_BROKERS=kafka:9092
-KAFKA_LOG_CONSUMER_GROP=log.sink.1
+KAFKA_LOG_CONSUMER_GROUP=log.sink.1
 KAFKA_LOG_CONSUMER_TOPIC=log.sink

main/logsink_suite_test.go

@@ -70,7 +70,7 @@ var _ = Describe("LogSink", func() {
 
 	BeforeSuite(func() {
 		kafkaBrokers := os.Getenv("KAFKA_BROKERS")
-		cGroup := os.Getenv("KAFKA_LOG_CONSUMER_GROP")
+		cGroup := os.Getenv("KAFKA_LOG_CONSUMER_GROUP")
 		topic = os.Getenv("KAFKA_LOG_CONSUMER_TOPIC")
 
 		var err error

main/main.go

@@ -24,7 +24,7 @@ func loadAndValidateEnv() error {
 
 	missingVar, err := commonutil.ValidateEnv(
 		"KAFKA_BROKERS",
-		"KAFKA_LOG_CONSUMER_GROP",
+		"KAFKA_LOG_CONSUMER_GROUP",
 		"KAFKA_LOG_CONSUMER_TOPIC",
 	)
 	if err != nil {
@@ -42,7 +42,7 @@ func main() {
 	}
 
 	kafkaBrokers := os.Getenv("KAFKA_BROKERS")
-	cGroup := os.Getenv("KAFKA_LOG_CONSUMER_GROP")
+	cGroup := os.Getenv("KAFKA_LOG_CONSUMER_GROUP")
 	cTopic := os.Getenv("KAFKA_LOG_CONSUMER_TOPIC")
 
 	consumer, err := kafka.NewConsumer(&kafka.ConsumerConfig{