From 85e829b8b4c8e66d698761923f7520bbf8ac993b Mon Sep 17 00:00:00 2001 From: slaventius Date: Thu, 2 Feb 2023 11:07:10 +0300 Subject: [PATCH] * --- internal/transport/kafka/kafka_writer.go | 4 +--- 1 file changed, 1 insertion(+), 3 deletions(-) diff --git a/internal/transport/kafka/kafka_writer.go b/internal/transport/kafka/kafka_writer.go index 434b79b..2ad9cd0 100644 --- a/internal/transport/kafka/kafka_writer.go +++ b/internal/transport/kafka/kafka_writer.go @@ -115,10 +115,8 @@ func (s *KafkaWriter) checkTopic() error { } func (s *KafkaWriter) WriteMessage(key string, value string) error { - err := s.writer.WriteMessages(context.Background(), kafka.Message{ + return s.writer.WriteMessages(context.Background(), kafka.Message{ Key: []byte(key), Value: []byte(value), }) - - return err }