*

2 years ago · 29bc6ff12f
parent 5cdcccea9a
commit 29bc6ff12f
1 changed files with 1 additions and 1 deletions
--- a/internal/transport/kafka/writer.go
+++ b/internal/transport/kafka/writer.go
@ -105,7 +105,7 @@ func NewWriter(ctx context.Context, topic string, address ...string) *KafkaWrite
 		topic: topic,
 	}

-	// Приверим и при необходимости создадим топик
+	// Проверим и при необходимости создадим топик
 	era := s.checkTopic()
 	if era != nil {
 		log.Fatal(era)