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);
}
}