fix: Version bump Pub/Sub Lite and make fixes to not create many chan…

…nels
googleapis · Dec 29, 2021 · a114161 · a114161
1 parent e69c74d
commit a114161
Showing 1 changed file with 7 additions and 2 deletions.
diff --git a/src/main/java/com/google/cloud/pubsublite/kafka/ProducerSettings.java b/src/main/java/com/google/cloud/pubsublite/kafka/ProducerSettings.java
@@ -29,8 +29,13 @@
 import com.google.cloud.pubsublite.MessageMetadata;
 import com.google.cloud.pubsublite.Partition;
 import com.google.cloud.pubsublite.TopicPath;
-import com.google.cloud.pubsublite.internal.wire.*;
+import com.google.cloud.pubsublite.internal.Publisher;
+import com.google.cloud.pubsublite.internal.wire.PartitionCountWatchingPublisherSettings;
+import com.google.cloud.pubsublite.internal.wire.PartitionPublisherFactory;
+import com.google.cloud.pubsublite.internal.wire.PubsubContext;
 import com.google.cloud.pubsublite.internal.wire.PubsubContext.Framework;
+import com.google.cloud.pubsublite.internal.wire.RoutingMetadata;
+import com.google.cloud.pubsublite.internal.wire.SinglePartitionPublisherBuilder;
 import com.google.cloud.pubsublite.v1.PublisherServiceClient;
 import com.google.cloud.pubsublite.v1.PublisherServiceSettings;
 import org.apache.kafka.clients.producer.Producer;
@@ -73,7 +78,7 @@ private PartitionPublisherFactory getPartitionPublisherFactory() {
     PublisherServiceClient client = newServiceClient();
     return new PartitionPublisherFactory() {
       @Override
-      public com.google.cloud.pubsublite.internal.Publisher<MessageMetadata> newPublisher(
+      public Publisher<MessageMetadata> newPublisher(
           Partition partition) throws ApiException {
         SinglePartitionPublisherBuilder.Builder singlePartitionBuilder =
             SinglePartitionPublisherBuilder.newBuilder()