[flink-connector-gcp-pubsub] 08/19: [FLINK-18448][pubsub] Update Google Cloud PubSub dependencies

[martijnvisser]

This is an automated email from the ASF dual-hosted git repository.

martijnvisser pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/flink-connector-gcp-pubsub.git

commit 3cdd0ac185c3674d754ac16739519dbbc8a0eb6f
Author: Niels Basjes <ni...@basjes.nl>
AuthorDate: Wed Jul 8 13:13:11 2020 +0200

    [FLINK-18448][pubsub] Update Google Cloud PubSub dependencies
    
    This closes #12846
---
 .../apache/flink/streaming/examples/gcp/pubsub/PubSubPublisher.java   | 4 ++--
 1 file changed, 2 insertions(+), 2 deletions(-)

diff --git 
a/flink-examples-streaming-gcp-pubsub/src/main/java/org/apache/flink/streaming/examples/gcp/pubsub/PubSubPublisher.java
 
b/flink-examples-streaming-gcp-pubsub/src/main/java/org/apache/flink/streaming/examples/gcp/pubsub/PubSubPublisher.java
index 8f7bfe6..ef9ad83 100644
--- 
a/flink-examples-streaming-gcp-pubsub/src/main/java/org/apache/flink/streaming/examples/gcp/pubsub/PubSubPublisher.java
+++ 
b/flink-examples-streaming-gcp-pubsub/src/main/java/org/apache/flink/streaming/examples/gcp/pubsub/PubSubPublisher.java
@@ -19,8 +19,8 @@ package org.apache.flink.streaming.examples.gcp.pubsub;
 
 import com.google.cloud.pubsub.v1.Publisher;
 import com.google.protobuf.ByteString;
-import com.google.pubsub.v1.ProjectTopicName;
 import com.google.pubsub.v1.PubsubMessage;
+import com.google.pubsub.v1.TopicName;
 
 import java.math.BigInteger;
 
@@ -44,7 +44,7 @@ class PubSubPublisher {
        void publish(int amountOfMessages) {
                Publisher publisher = null;
                try {
-                       publisher = 
Publisher.newBuilder(ProjectTopicName.of(projectName, topicName)).build();
+                       publisher = 
Publisher.newBuilder(TopicName.of(projectName, topicName)).build();
                        for (int i = 0; i < amountOfMessages; i++) {
                                ByteString messageData = 
ByteString.copyFrom(BigInteger.valueOf(i).toByteArray());
                                PubsubMessage message = 
PubsubMessage.newBuilder().setData(messageData).build();