From d55d82c00960ad5d3c1a08dfe4f18af79abb906b Mon Sep 17 00:00:00 2001 From: Russia9 Date: Tue, 27 Sep 2022 18:14:51 +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 85c2b5d..0d06271 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-duels", + "group.id": "cw2-duels", "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 }