removed comments

yugabyte · Sep 19, 2024 · 2d557f0 · 2d557f0
1 parent 57824c8
commit 2d557f0
Showing 1 changed file with 0 additions and 6 deletions.
diff --git a/...onnector-postgres/src/test/java/io/debezium/connector/postgresql/PostgresConnectorIT.java b/...onnector-postgres/src/test/java/io/debezium/connector/postgresql/PostgresConnectorIT.java
@@ -3000,9 +3000,6 @@ public void testPerf() throws Exception {
             long timeDifference = System.currentTimeMillis() - lastLoggedTime;
             if (timeDifference >= 10_000) {
                 long currentValue = (long) mBeanServer.getAttribute(getStreamingMetricsObjectName("postgres", TestHelper.TEST_SERVER), "TotalNumberOfEventsSeen");
-//                int queueRemainingCapacity = (int) mBeanServer.getAttribute(getStreamingMetricsObjectName("postgres", TestHelper.TEST_SERVER), "QueueRemainingCapacity");
-//                LOGGER.info("Queue remaining capacity: {}", queueRemainingCapacity);
-//                LOGGER.info("Current consumed value {}", currentValue);
                 LOGGER.info("Streaming rate currently is {}", (currentValue - lastReadValue) / (timeDifference / 1000));
                 lastLoggedTime = System.currentTimeMillis();
                 lastReadValue = currentValue;
@@ -4176,9 +4173,6 @@ protected int consumeAvailableRecords(Consumer<SourceRecord> recordConsumer) {
         return records.size();
     }
 
-//    protected int consumeAvailableRecordsAndClearQueue() {
-//    }
-
     @Test
     @FixFor("DBZ-6076")
     public void shouldUseDefaultSourceInfoStructMaker() throws InterruptedException {