From 47821486cf65b5581dc75f47486b89de86b382e8 Mon Sep 17 00:00:00 2001 From: git Date: Sat, 28 Dec 2019 03:17:38 -0500 Subject: [PATCH] Change the default pubsub client to the GRPC client from the json one. --- .../main/java/org/apache/beam/sdk/io/gcp/pubsub/PubsubIO.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/pubsub/PubsubIO.java b/sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/pubsub/PubsubIO.java index 790e4677af1c7..b9863a0de3eb5 100644 --- a/sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/pubsub/PubsubIO.java +++ b/sdks/java/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