code: protected static void createS3Bucket() throws Exception {
          if (StringUtils.isNullOrEmpty(s3BucketName.trim())) {
              throw new IllegalArgumentException("Bucket name is empty. Please enter a bucket name "
                      + "in firehosetos3sample.properties file");
          }
  
          // Create S3 bucket if specified in the properties
          if (createS3Bucket) {
              s3Client.createBucket(s3BucketName);
              LOG.info("Created bucket " + s3BucketName + " in S3 to deliver Firehose records");
          }
      }
docs: Method to create the S3 bucket in specified region.
  
  @throws Exception