diff --git a/pubsub/cloud-client/pom.xml b/pubsub/cloud-client/pom.xml
index 719e0cfb813..4d111be0fee 100644
--- a/pubsub/cloud-client/pom.xml
+++ b/pubsub/cloud-client/pom.xml
@@ -31,7 +31,7 @@
1.8
1.8
UTF-8
- 0.9.4-alpha
+ 0.11.2-alpha
diff --git a/pubsub/cloud-client/src/main/java/com/example/pubsub/QuickstartSample.java b/pubsub/cloud-client/src/main/java/com/example/pubsub/QuickstartSample.java
index ac5dcefc2af..d37c3cdafd6 100644
--- a/pubsub/cloud-client/src/main/java/com/example/pubsub/QuickstartSample.java
+++ b/pubsub/cloud-client/src/main/java/com/example/pubsub/QuickstartSample.java
@@ -20,7 +20,7 @@
// Imports the Google Cloud client library
import com.google.cloud.ServiceOptions;
-import com.google.cloud.pubsub.spi.v1.PublisherClient;
+import com.google.cloud.pubsub.spi.v1.TopicAdminClient;
import com.google.pubsub.v1.TopicName;
public class QuickstartSample {
@@ -35,8 +35,8 @@ public static void main(String... args) throws Exception {
// Create a new topic
TopicName topic = TopicName.create(projectId, topicId);
- try (PublisherClient publisherClient = PublisherClient.create()) {
- publisherClient.createTopic(topic);
+ try (TopicAdminClient topicAdminClient = TopicAdminClient.create()) {
+ topicAdminClient.createTopic(topic);
}
System.out.printf("Topic %s:%s created.\n", topic.getProject(), topic.getTopic());
diff --git a/pubsub/cloud-client/src/test/java/com/example/pubsub/QuickstartSampleIT.java b/pubsub/cloud-client/src/test/java/com/example/pubsub/QuickstartSampleIT.java
index d293cd30bb6..bd5a781ccf3 100644
--- a/pubsub/cloud-client/src/test/java/com/example/pubsub/QuickstartSampleIT.java
+++ b/pubsub/cloud-client/src/test/java/com/example/pubsub/QuickstartSampleIT.java
@@ -19,7 +19,7 @@
import static com.google.common.truth.Truth.assertThat;
import com.google.cloud.ServiceOptions;
-import com.google.cloud.pubsub.spi.v1.PublisherClient;
+import com.google.cloud.pubsub.spi.v1.TopicAdminClient;
import com.google.pubsub.v1.TopicName;
import org.junit.After;
@@ -43,8 +43,8 @@ public class QuickstartSampleIT {
private PrintStream out;
private void deleteTestTopic() throws Exception {
- try (PublisherClient publisherClient = PublisherClient.create()) {
- publisherClient.deleteTopic(
+ try (TopicAdminClient topicAdminClient = TopicAdminClient.create()) {
+ topicAdminClient.deleteTopic(
TopicName.create(ServiceOptions.getDefaultProjectId(), "my-new-topic"));
} catch (IOException e) {
System.err.println("Error deleting topic " + e.getMessage());