diff --git a/google-cloud-pubsub/src/main/java/com/google/cloud/pubsub/v1/StreamingSubscriberConnection.java b/google-cloud-pubsub/src/main/java/com/google/cloud/pubsub/v1/StreamingSubscriberConnection.java index 5c9f9e171..2ee077597 100644 --- a/google-cloud-pubsub/src/main/java/com/google/cloud/pubsub/v1/StreamingSubscriberConnection.java +++ b/google-cloud-pubsub/src/main/java/com/google/cloud/pubsub/v1/StreamingSubscriberConnection.java @@ -519,7 +519,7 @@ private void startServerMonitor() { } logger.log( - Level.WARNING, + Level.INFO, "No response from server for {0} seconds since last ping. Closing stream.", elapsedSincePing.getSeconds()); diff --git a/google-cloud-pubsub/src/main/java/com/google/cloud/pubsub/v1/Subscriber.java b/google-cloud-pubsub/src/main/java/com/google/cloud/pubsub/v1/Subscriber.java index a2d4f3b38..37440ba40 100644 --- a/google-cloud-pubsub/src/main/java/com/google/cloud/pubsub/v1/Subscriber.java +++ b/google-cloud-pubsub/src/main/java/com/google/cloud/pubsub/v1/Subscriber.java @@ -144,7 +144,7 @@ public class Subscriber extends AbstractApiService implements SubscriberInterfac private final boolean maxDurationPerAckExtensionDefaultUsed; private final java.time.Duration minDurationPerAckExtension; private final boolean minDurationPerAckExtensionDefaultUsed; - private final long protocolVersion = 1L; + private final long protocolVersion = 0L; // The ExecutorProvider used to generate executors for processing messages. private final ExecutorProvider executorProvider;