more test logs for testDocumentInKafkaTransactionError

slackhq · Sep 21, 2023 · cbf6562 · cbf6562
1 parent c4787d5
commit cbf6562
Showing 1 changed file with 1 addition and 2 deletions.
diff --git a/kaldb/src/test/java/com/slack/kaldb/elasticsearchApi/OpenSearchBulkEndpointTest.java b/kaldb/src/test/java/com/slack/kaldb/elasticsearchApi/OpenSearchBulkEndpointTest.java
@@ -269,7 +269,6 @@ record ->
   }
 
   @Test
-  @Disabled("Flaky test")
   public void testDocumentInKafkaTransactionError() throws Exception {
     updateDatasetThroughput(100_1000);
 
@@ -340,7 +339,7 @@ public void validateOffset(KafkaConsumer kafkaConsumer, int offset) {
                           .stream()
                           .findFirst()
                           .get();
-              LOG.debug("Current partitionOffset - {}", partitionOffset);
+              LOG.debug("Current partitionOffset - {}. expecting offset to be - {}", partitionOffset, offset);
               return partitionOffset == offset;
             });
   }