diff --git a/app/app.go b/app/app.go index 8dd0747..a82404f 100644 --- a/app/app.go +++ b/app/app.go @@ -70,6 +70,7 @@ type Options struct { ModuleLogger string `env:"MODULE_LOGGER" default:"core-local"` ClickHouseCred string `env:"CLICK_HOUSE_CRED" default:"tcp://10.8.0.15:9000/default?sslmode=disable"` S3Prefix string `env:"S3_PREFIX"` + KafkaGroupGigaChat string `env:"KAFKA_GROUP_GIGA_CHAT" default:"gigachat"` KafkaTopicGigaChat string `env:"KAFKA_TOPIC_GIGA_CHAT"` } @@ -141,7 +142,7 @@ func New(ctx context.Context, opts interface{}, ver appInit.Version) (appInit.Co } kafkaClientGigaChat, err := initialize.KafkaInit(ctx, initialize.KafkaDeps{ - KafkaGroup: options.KafkaGroup, + KafkaGroup: options.KafkaGroupGigaChat, KafkaBrokers: options.KafkaBrokers, KafkaTopic: options.KafkaTopicGigaChat, })