def create_message(message)
      begin
        @producer.produce(JSON.dump(message), topic: @topic)
      rescue Kafka::BufferOverflow
        Octo.logger.error 'Buffer Overflow. Sleeping for 1s'
        sleep 1
        retry
      end
    end
def create_message(message)
      begin
        @producer.produce(JSON.dump(message), topic: @topic)
      rescue Kafka::BufferOverflow
        Octo.logger.error 'Buffer Overflow. Sleeping for 1s'
        sleep 1
        retry
      end
    end
Creates a new message.
 @param [Hash] message The message hash to be produced