Recreation of GRPC publisher/subscribers

kafka-connector/src/main/java/com/google/pubsub/kafka/sink/CloudPubSubGRPCPublisher.java

@@ -56,7 +56,8 @@ private void makePublisher() {
       log.info("Creating publisher.");
       publisher = PublisherGrpc.newFutureStub(ConnectorUtils.getChannel());
       // We change the publisher every 25 - 35 minutes in order to avoid GOAWAY errors.
-      nextPublisherResetTime = System.currentTimeMillis() + rand.nextInt(10 * 60 * 1000) + 25 * 60 * 1000;
+      nextPublisherResetTime =
+          System.currentTimeMillis() + rand.nextInt(10 * 60 * 1000) + 25 * 60 * 1000;
     } catch (IOException e) {
       throw new RuntimeException("Could not create publisher stub; no publishes can occur.", e);
     }

kafka-connector/src/main/java/com/google/pubsub/kafka/source/CloudPubSubGRPCSubscriber.java

@@ -44,7 +44,7 @@ public class CloudPubSubGRPCSubscriber implements CloudPubSubSubscriber {
     makeSubscriber();
   }
 
-  public ListenableFuture<PullResponse> pull(PullRequest request) {{
+  public ListenableFuture<PullResponse> pull(PullRequest request) {
     if (System.currentTimeMillis() > nextSubscriberResetTime) {
       makeSubscriber();
     }
@@ -63,7 +63,8 @@ private void makeSubscriber() {
       log.info("Creating subscriber.");
       subscriber = SubscriberGrpc.newFutureStub(ConnectorUtils.getChannel());
       // We change the subscriber every 25 - 35 minutes in order to avoid GOAWAY errors.
-      nextSubscriberResetTime = System.currentTimeMillis() + rand.nextInt(10 * 60 * 1000) + 25 * 60 * 1000;
+      nextSubscriberResetTime =
+          System.currentTimeMillis() + rand.nextInt(10 * 60 * 1000) + 25 * 60 * 1000;
     } catch (IOException e) {
       throw new RuntimeException("Could not create subscriber stub; no subscribing can occur.", e);
     }