return

GoogleCloudPlatform · May 3, 2024 · 1e7312c · 1e7312c
1 parent 0847cf5
commit 1e7312c
Showing 1 changed file with 1 addition and 0 deletions.
diff --git a/v2/kafka-to-gcs/src/main/java/com/google/cloud/teleport/v2/templates/KafkaToGcs2.java b/v2/kafka-to-gcs/src/main/java/com/google/cloud/teleport/v2/templates/KafkaToGcs2.java
@@ -276,6 +276,7 @@ public static void validateAuthOptions(KafkaToGcsOptions options) {
     // the dataflow pipeline and Kafka broker is on the same network.
     if (options.getUserNameSecretID().isBlank() && options.getPasswordSecretID().isBlank()) {
       useKafkaAuth = false;
+      return;
     }
 
     if ((options.getUserNameSecretID().isBlank() && !options.getPasswordSecretID().isBlank())