From 91eabc39dd5c0ebbb5eab9d31e2fe7c0c8723c6d Mon Sep 17 00:00:00 2001 From: Russia9 Date: Mon, 29 Aug 2022 16:23:27 +0300 Subject: [PATCH] cw2 --- app.go | 2 +- app/app.go | 2 +- 2 files changed, 2 insertions(+), 2 deletions(-) diff --git a/app.go b/app.go index 306134e..d0504f2 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", "auto.offset.reset": "latest", }) if err != nil { diff --git a/app/app.go b/app/app.go index c567223..fd03142 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-duels"}, nil) + err := consumer.SubscribeTopics([]string{"cw2-duels"}, nil) if err != nil { return err }