Browse Source

cw2

master
Andrey Kovalev 2 years ago
parent
commit
58c0c0feb9
Signed by: Russia9
GPG Key ID: EC3AA65373CA51DC
  1. 2
      app.go
  2. 2
      app/app.go

2
app.go

@ -44,7 +44,7 @@ func main() { @@ -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 {

2
app/app.go

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

Loading…
Cancel
Save