cw2

app.go

@@ -44,7 +44,7 @@ func main() {
 	// Kafka consumer init
 	consumer, err := kafka.NewConsumer(&kafka.ConfigMap{
 		"bootstrap.servers": utils.GetEnv("KAFKA_ADDRESS", "localhost"),
-		"group.id":          "cw3",
+		"group.id":          "cw2-deals",
 		"auto.offset.reset": "latest",
 	})
 	if err != nil {

app/app.go

@@ -21,7 +21,7 @@ func Init(bot *telebot.Bot, chat *telebot.Chat, consumer *kafka.Consumer) error
 		Consumer: consumer,
 	}
 
-	err := consumer.SubscribeTopics([]string{"cw3-deals"}, nil)
+	err := consumer.SubscribeTopics([]string{"cw2-deals"}, nil)
 	if err != nil {
 		return err
 	}