Remove debug logging

apache · Oct 1, 2024 · a2744e6 · a2744e6
1 parent 868f37e
commit a2744e6
Showing 1 changed file with 0 additions and 8 deletions.
diff --git a/sdks/java/io/kafka/src/main/java/org/apache/beam/sdk/io/kafka/ReadFromKafkaDoFn.java b/sdks/java/io/kafka/src/main/java/org/apache/beam/sdk/io/kafka/ReadFromKafkaDoFn.java
@@ -422,14 +422,6 @@ public ProcessContinuation processElement(
               Optional.ofNullable(watermarkEstimator.currentWatermark()));
     }
     final long startOffset = tracker.currentRestriction().getFrom();
-    String restrictionInfo =
-        String.format(
-            "%s_%s_%s",
-            kafkaSourceDescriptor.getTopic(), kafkaSourceDescriptor.getPartition(), startOffset);
-    if (kafkaSourceDescriptor.getPartition() == 42) {
-      LOG.info(
-          "{} bzablockilog start restriction {}", Thread.currentThread().getId(), restrictionInfo);
-    }
     long resumeOffset = startOffset;
     @Nullable KafkaConsumerPollThread pollThread = null;
     try {