*

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
 }