diff --git a/app/app.go b/app/app.go index 53a12e8..c567223 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{"cw3-duels"}, nil) if err != nil { return err }