File tree Expand file tree Collapse file tree
src/main/java/pubsublite/spark Expand file tree Collapse file tree Original file line number Diff line number Diff line change 4444 <dependency >
4545 <groupId >com.google.cloud</groupId >
4646 <artifactId >google-cloud-pubsublite</artifactId >
47- <version >0.8 .0</version >
47+ <version >0.10 .0</version >
4848 </dependency >
4949 <dependency >
5050 <groupId >junit</groupId >
Original file line number Diff line number Diff line change 4444 <dependency >
4545 <groupId >com.google.cloud</groupId >
4646 <artifactId >google-cloud-pubsublite</artifactId >
47- <version >0.8 .0</version >
47+ <version >0.10 .0</version >
4848 </dependency >
4949 <dependency >
5050 <groupId >junit</groupId >
Original file line number Diff line number Diff line change 2424import com .google .cloud .pubsublite .AdminClientSettings ;
2525import com .google .cloud .pubsublite .CloudRegion ;
2626import com .google .cloud .pubsublite .CloudZone ;
27+ import com .google .cloud .pubsublite .MessageMetadata ;
2728import com .google .cloud .pubsublite .ProjectNumber ;
28- import com .google .cloud .pubsublite .PublishMetadata ;
2929import com .google .cloud .pubsublite .SubscriptionName ;
3030import com .google .cloud .pubsublite .SubscriptionPath ;
3131import com .google .cloud .pubsublite .TopicName ;
@@ -193,11 +193,11 @@ public static void publisherExample(
193193 futures .add (future );
194194 }
195195 } finally {
196- ArrayList <PublishMetadata > metadata = new ArrayList <>();
196+ ArrayList <MessageMetadata > metadata = new ArrayList <>();
197197 List <String > ackIds = ApiFutures .allAsList (futures ).get ();
198198 for (String id : ackIds ) {
199199 // Decoded metadata contains partition and offset.
200- metadata .add (PublishMetadata .decode (id ));
200+ metadata .add (MessageMetadata .decode (id ));
201201 }
202202 System .out .println (metadata + "\n Published " + ackIds .size () + " messages." );
203203
You can’t perform that action at this time.
0 commit comments