From 29bc6ff12f2f9823a196db86d0be4680bcecc9d1 Mon Sep 17 00:00:00 2001 From: slaventius Date: Tue, 7 Feb 2023 17:41:14 +0300 Subject: [PATCH] * --- internal/transport/kafka/writer.go | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/internal/transport/kafka/writer.go b/internal/transport/kafka/writer.go index 2765e80..aa1e9cf 100644 --- 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)