SQuiz/amocrm
2
0
Fork 0
Code Issues Pull Requests 1 Actions Packages Projects Releases Wiki Activity

-

Browse Source
This commit is contained in:
pasha1coil 2025-02-25 13:04:58 +03:00
parent 87ec802812
commit 0bcc2a51fa
2 changed files with 10 additions and 10 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
internal/initialize/config.go
View File

@ -10,7 +10,7 @@ type Config struct {
ClientHttpURL string `env:"CLIENT_HTTP_URL" envDefault:"0.0.0.0:8001"`
PostgresURL string `env:"POSTGRES_URL" envDefault:"host=localhost port=5432 user=squiz password=Redalert2 dbname=squiz sslmode=disable"`
KafkaBrokers string `env:"KAFKA_BROKERS" envDefault:"localhost:9092"`
KafkaTopicQueue string `env:"KAFKA_TOPIC" envDefault:"test-topic"`
KafkaTopicQueueAmo string `env:"KAFKA_TOPIC_QUEUE_AMO" envDefault:"test-topic"`
KafkaGroup string `env:"KAFKA_GROUP" envDefault:"amoCRM"`
RedisHost string `env:"REDIS_HOST" envDefault:"localhost:6379"`
RedisPassword string `env:"REDIS_PASSWORD" envDefault:"admin"`

4
internal/initialize/kafka.go
View File

@ -10,8 +10,8 @@ func KafkaConsumerInit(ctx context.Context, config Config) (*kgo.Client, error)
kafkaClient, err := kgo.NewClient(
kgo.SeedBrokers(config.KafkaBrokers),
kgo.ConsumerGroup(config.KafkaGroup),
kgo.DefaultProduceTopic(config.KafkaTopicQueue),
kgo.ConsumeTopics(config.KafkaTopicQueue),
kgo.DefaultProduceTopic(config.KafkaTopicQueueAmo),
kgo.ConsumeTopics(config.KafkaTopicQueueAmo),
kgo.ConsumeResetOffset(kgo.NewOffset().AfterMilli(time.Now().UnixMilli())),
)
if err != nil {