SQuiz/core
2
0
Fork 0
Code Issues Pull Requests 3 Actions Packages Projects Releases Wiki Activity

update commmon and sep kafka group

Browse Source
This commit is contained in:
Pasha 2025-05-14 13:47:38 +03:00
parent a415823f84
commit c9cf3b07b1
1 changed files with 2 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

3
app/app.go
View File

@ -70,6 +70,7 @@ type Options struct {
ModuleLogger string `env:"MODULE_LOGGER" default:"core-local"` ModuleLogger string `env:"MODULE_LOGGER" default:"core-local"`
ClickHouseCred string `env:"CLICK_HOUSE_CRED" default:"tcp://10.8.0.15:9000/default?sslmode=disable"` ClickHouseCred string `env:"CLICK_HOUSE_CRED" default:"tcp://10.8.0.15:9000/default?sslmode=disable"`
S3Prefix string `env:"S3_PREFIX"` S3Prefix string `env:"S3_PREFIX"`
KafkaGroupGigaChat string `env:"KAFKA_GROUP_GIGA_CHAT" default:"gigachat"`
KafkaTopicGigaChat string `env:"KAFKA_TOPIC_GIGA_CHAT"` 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{ kafkaClientGigaChat, err := initialize.KafkaInit(ctx, initialize.KafkaDeps{
KafkaGroup: options.KafkaGroup, KafkaGroup: options.KafkaGroupGigaChat,
KafkaBrokers: options.KafkaBrokers, KafkaBrokers: options.KafkaBrokers,
KafkaTopic: options.KafkaTopicGigaChat, KafkaTopic: options.KafkaTopicGigaChat,
}) })