From c8caf0c61588897d4bf72c077162f7b3a9b32fcf Mon Sep 17 00:00:00 2001
From: Danny Mccormick <dannymccormick@google.com>
Date: Mon, 23 Dec 2024 19:36:20 -0500
Subject: [PATCH] Debug info

---
 .../apache/beam/sdk/io/aws2/common/ClientBuilderFactory.java   | 1 +
 .../beam/sdk/io/aws2/kinesis/KinesisTransformRegistrar.java    | 3 +++
 2 files changed, 4 insertions(+)

diff --git a/sdks/java/io/amazon-web-services2/src/main/java/org/apache/beam/sdk/io/aws2/common/ClientBuilderFactory.java b/sdks/java/io/amazon-web-services2/src/main/java/org/apache/beam/sdk/io/aws2/common/ClientBuilderFactory.java
index e0b3646f364..d21aa7f0ec5 100644
--- a/sdks/java/io/amazon-web-services2/src/main/java/org/apache/beam/sdk/io/aws2/common/ClientBuilderFactory.java
+++ b/sdks/java/io/amazon-web-services2/src/main/java/org/apache/beam/sdk/io/aws2/common/ClientBuilderFactory.java
@@ -165,6 +165,7 @@ public <BuilderT extends AwsClientBuilder<BuilderT, ClientT>, ClientT> BuilderT
       boolean skipCertificateVerification = false;
       if (config.skipCertificateVerification() != null) {
         skipCertificateVerification = config.skipCertificateVerification();
+        throw new RuntimeException("config was non-null " + skipCertificateVerification);
       }
       if (proxyConfig != null || httpConfig != null || skipCertificateVerification) {
         if (builder instanceof SdkSyncClientBuilder) {
diff --git a/sdks/java/io/amazon-web-services2/src/main/java/org/apache/beam/sdk/io/aws2/kinesis/KinesisTransformRegistrar.java b/sdks/java/io/amazon-web-services2/src/main/java/org/apache/beam/sdk/io/aws2/kinesis/KinesisTransformRegistrar.java
index 11e51787297..2b5d628e312 100644
--- a/sdks/java/io/amazon-web-services2/src/main/java/org/apache/beam/sdk/io/aws2/kinesis/KinesisTransformRegistrar.java
+++ b/sdks/java/io/amazon-web-services2/src/main/java/org/apache/beam/sdk/io/aws2/kinesis/KinesisTransformRegistrar.java
@@ -120,6 +120,9 @@ public PTransform<PCollection<byte[]>, KinesisIO.Write.Result> buildExternal(
                   "Service endpoint must be URI format, got: %s", configuration.serviceEndpoint));
         }
       }
+      if (configuration.verifyCertificate) {
+        throw new RuntimeException("This is the problem");
+      }
       KinesisIO.Write<byte[]> writeTransform =
           KinesisIO.<byte[]>write()
               .withStreamName(configuration.streamName)