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
 }