diff --git a/.env b/.env index 3ce0765..61d653c 100644 --- a/.env +++ b/.env @@ -8,7 +8,8 @@ MONGO_AUTH="admin" # Kafka settings KAFKA_BROKERS="localhost:9092" -KAFKA_TOPIC_TARIFF="test-topic" +KAFKA_TOPIC="test-topic" +KAFKA_GROUP="mailnotifier" # SMTP settings SMTP_API_URL="https://api.smtp.bz/v1/smtp/send" diff --git a/internal/initialize/config.go b/internal/initialize/config.go index 6295e64..a3167d0 100644 --- a/internal/initialize/config.go +++ b/internal/initialize/config.go @@ -14,7 +14,8 @@ type Config struct { MongoDatabase string `env:"MONGO_DB" envDefault:"admin"` MongoAuth string `env:"MONGO_AUTH" envDefault:"admin"` KafkaBrokers string `env:"KAFKA_BROKERS"` - KafkaTopic string `env:"KAFKA_TOPIC_TARIFF"` + KafkaTopic string `env:"KAFKA_TOPIC"` + KafkaGroup string `env:"KAFKA_GROUP" default:"mailnotifier"` SmtpApiUrl string `env:"SMTP_API_URL"` SmtpHost string `env:"SMTP_HOST"` SmtpPort string `env:"SMTP_PORT"` diff --git a/internal/initialize/kafka.go b/internal/initialize/kafka.go index cdb3d17..14ab974 100644 --- a/internal/initialize/kafka.go +++ b/internal/initialize/kafka.go @@ -9,7 +9,7 @@ import ( func KafkaConsumerInit(ctx context.Context, config Config) (*kgo.Client, error) { kafkaClient, err := kgo.NewClient( kgo.SeedBrokers(config.KafkaBrokers), - kgo.ConsumerGroup("mailnotifier"), + kgo.ConsumerGroup(config.KafkaGroup), kgo.ConsumeTopics(config.KafkaTopic), kgo.ConsumeResetOffset(kgo.NewOffset().AfterMilli(time.Now().UnixMilli())), )