Change the default pubsub client to the GRPC client from the json one.

apache · Dec 28, 2019 · 4782148 · 4782148
1 parent 452a9ca
commit 4782148
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/...va/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/pubsub/PubsubIO.java b/...va/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/pubsub/PubsubIO.java
@@ -82,7 +82,7 @@ public class PubsubIO {
   private static final Logger LOG = LoggerFactory.getLogger(PubsubIO.class);
 
   /** Factory for creating pubsub client to manage transport. */
-  private static final PubsubClient.PubsubClientFactory FACTORY = PubsubJsonClient.FACTORY;
+  private static final PubsubClient.PubsubClientFactory FACTORY = PubsubGrpcClient.FACTORY;
 
   /**
    * Project IDs must contain 6-63 lowercase letters, digits, or dashes. IDs must start with a