lib/kafkr/producer.rb in kafkr-0.13.0 vs lib/kafkr/producer.rb in kafkr-0.18.0

@@ -48,9 +48,11 @@
         {type.to_sym => hash_body}
       end
     end
 
     def self.send_message(message)
+      return if message.nil? || message.empty?
+
       uuid = SecureRandom.uuid
       message_with_uuid = nil
 
       if Kafkr::Producer.configuration.is_json
         json_message = JSON.parse(message)