diff --git a/src/main/java/com/google/cloud/pubsublite/flink/PubsubLiteSourceSettings.java b/src/main/java/com/google/cloud/pubsublite/flink/PubsubLiteSourceSettings.java
index 4c3e9f02..4902df19 100644
--- a/src/main/java/com/google/cloud/pubsublite/flink/PubsubLiteSourceSettings.java
+++ b/src/main/java/com/google/cloud/pubsublite/flink/PubsubLiteSourceSettings.java
@@ -29,7 +29,13 @@
 import com.google.cloud.pubsublite.SequencedMessage;
 import com.google.cloud.pubsublite.SubscriptionPath;
 import com.google.cloud.pubsublite.cloudpubsub.FlowControlSettings;
-import com.google.cloud.pubsublite.flink.internal.reader.*;
+import com.google.cloud.pubsublite.flink.internal.reader.CompletablePullSubscriber;
+import com.google.cloud.pubsublite.flink.internal.reader.CompletablePullSubscriberImpl;
+import com.google.cloud.pubsublite.flink.internal.reader.ConditionallyCompleteSubscriberFactory;
+import com.google.cloud.pubsublite.flink.internal.reader.DeserializingSplitReader;
+import com.google.cloud.pubsublite.flink.internal.reader.MessageSplitReader;
+import com.google.cloud.pubsublite.flink.internal.reader.PartitionFinishedCondition;
+import com.google.cloud.pubsublite.flink.internal.reader.Record;
 import com.google.cloud.pubsublite.flink.internal.split.SubscriptionPartitionSplit;
 import com.google.cloud.pubsublite.internal.BlockingPullSubscriberImpl;
 import com.google.cloud.pubsublite.internal.CursorClient;