From 18f8ffa2809af590a42e8a20c259f02e9f626164 Mon Sep 17 00:00:00 2001
From: Derrick Williams <derrickaw@google.com>
Date: Fri, 1 May 2026 19:45:59 +0000
Subject: [PATCH] Remove unused logTopicVerification field from
 GenerateKafkaSourceDescriptor

---
 .../src/main/java/org/apache/beam/sdk/io/kafka/KafkaIO.java     | 2 --
 1 file changed, 2 deletions(-)

diff --git a/sdks/java/io/kafka/src/main/java/org/apache/beam/sdk/io/kafka/KafkaIO.java b/sdks/java/io/kafka/src/main/java/org/apache/beam/sdk/io/kafka/KafkaIO.java
index f9bfdd87aaac..3678ebf3bb0a 100644
--- a/sdks/java/io/kafka/src/main/java/org/apache/beam/sdk/io/kafka/KafkaIO.java
+++ b/sdks/java/io/kafka/src/main/java/org/apache/beam/sdk/io/kafka/KafkaIO.java
@@ -2091,7 +2091,6 @@ static class GenerateKafkaSourceDescriptor extends DoFn<byte[], KafkaSourceDescr
         this.topicPattern = read.getTopicPattern();
         this.startReadTime = read.getStartReadTime();
         this.stopReadTime = read.getStopReadTime();
-        this.logTopicVerification = read.getLogTopicVerification();
       }
 
       private final SerializableFunction<Map<String, Object>, Consumer<byte[], byte[]>>
@@ -2108,7 +2107,6 @@ static class GenerateKafkaSourceDescriptor extends DoFn<byte[], KafkaSourceDescr
       @VisibleForTesting final @Nullable List<String> topics;
 
       private final @Nullable Pattern topicPattern;
-      private final @Nullable Boolean logTopicVerification;
 
       @ProcessElement
       public void processElement(OutputReceiver<KafkaSourceDescriptor> receiver) {