diff --git a/samples/snapshot/pom.xml b/samples/snapshot/pom.xml index b5578f6f..f730fc6b 100644 --- a/samples/snapshot/pom.xml +++ b/samples/snapshot/pom.xml @@ -44,7 +44,7 @@ com.google.cloud google-cloud-pubsublite - 0.8.0 + 0.10.0 junit diff --git a/samples/snippets/pom.xml b/samples/snippets/pom.xml index 84552347..71096938 100644 --- a/samples/snippets/pom.xml +++ b/samples/snippets/pom.xml @@ -44,7 +44,7 @@ com.google.cloud google-cloud-pubsublite - 0.8.0 + 0.10.0 junit diff --git a/samples/snippets/src/main/java/pubsublite/spark/AdminUtils.java b/samples/snippets/src/main/java/pubsublite/spark/AdminUtils.java index 8a284905..09bac836 100644 --- a/samples/snippets/src/main/java/pubsublite/spark/AdminUtils.java +++ b/samples/snippets/src/main/java/pubsublite/spark/AdminUtils.java @@ -24,8 +24,8 @@ import com.google.cloud.pubsublite.AdminClientSettings; import com.google.cloud.pubsublite.CloudRegion; import com.google.cloud.pubsublite.CloudZone; +import com.google.cloud.pubsublite.MessageMetadata; import com.google.cloud.pubsublite.ProjectNumber; -import com.google.cloud.pubsublite.PublishMetadata; import com.google.cloud.pubsublite.SubscriptionName; import com.google.cloud.pubsublite.SubscriptionPath; import com.google.cloud.pubsublite.TopicName; @@ -193,11 +193,11 @@ public static void publisherExample( futures.add(future); } } finally { - ArrayList metadata = new ArrayList<>(); + ArrayList metadata = new ArrayList<>(); List ackIds = ApiFutures.allAsList(futures).get(); for (String id : ackIds) { // Decoded metadata contains partition and offset. - metadata.add(PublishMetadata.decode(id)); + metadata.add(MessageMetadata.decode(id)); } System.out.println(metadata + "\nPublished " + ackIds.size() + " messages.");