diff --git a/app.go b/app.go
index 0f8a164..0aa3cee 100644
--- a/app.go
+++ b/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 {
diff --git a/app/app.go b/app/app.go
index 3899aee..2b38af6 100644
--- a/app/app.go
+++ b/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
 	}