private void createTopic()

in ordering-keys-prober/src/main/java/com/google/cloud/pubsub/prober/Prober.java [503:516]


  private void createTopic() {
    logger.info("Creating topic " + fullTopicName);
    Topic.Builder builder = Topic.newBuilder().setName(fullTopicName.toString());
    builder = updateTopicBuilder(builder);
    try {
      topicAdminClient.createTopic(builder.build());
      logger.info("Created topic " + fullTopicName);
    } catch (Exception e) {
      if (e instanceof InterruptedException) {
        Thread.currentThread().interrupt();
      }
      logger.log(Level.WARNING, "Failed to create topic " + fullTopicName, e);
    }
  }