diff --git a/internal/initialize/config.go b/internal/initialize/config.go
index a49d865..7796a58 100644
--- a/internal/initialize/config.go
+++ b/internal/initialize/config.go
@@ -7,14 +7,14 @@ import (
 )
 
 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"`
-	KafkaGroup      string `env:"KAFKA_GROUP" envDefault:"amoCRM"`
-	RedisHost       string `env:"REDIS_HOST" envDefault:"localhost:6379"`
-	RedisPassword   string `env:"REDIS_PASSWORD" envDefault:"admin"`
-	RedisDB         int    `env:"REDIS_DB" envDefault:"2"`
+	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"`
+	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"`
+	RedisDB            int    `env:"REDIS_DB" envDefault:"2"`
 	// урл в соц аус сервисе для генерации ссылки для авторизации в амо
 	PenaSocialAuthMicroserviceURL string `env:"PENA_SOCIAL_AUTH_MICROSERVICE_URL" envDefault:"http://localhost:8000/amocrm/auth"`
 	// урл на который будет возвращен пользователь после авторизации это webhook/create get
diff --git a/internal/initialize/kafka.go b/internal/initialize/kafka.go
index e135d73..61c8ceb 100644
--- a/internal/initialize/kafka.go
+++ b/internal/initialize/kafka.go
@@ -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 {