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)