Merge branch 'beam-pubsub' into firestore-test

theodolite-benchmarks/uc1-beam/src/main/java/rocks/theodolite/benchmarks/uc1/beam/pubsub/PubSubSource.java

@@ -45,7 +45,8 @@ public final class PubSubSource extends PTransform<PBegin, PCollection<ActivePow
       final String subscriptionName) {
     return new PubSubSource(PubsubIO
         .readMessages()
-        .fromTopic(PubSubSubscriptionFactory.create(projectName, subscriptionName).asPath()));
+        .fromSubscription(
+            PubSubSubscriptionFactory.create(projectName, subscriptionName).asPath()));
   }
 
 }