diff --git a/metadata/src/test/java/org/apache/kafka/metalog/LocalLogManager.java b/metadata/src/test/java/org/apache/kafka/metalog/LocalLogManager.java index 3c495adff9268..36fe3ec2c1c58 100644 --- a/metadata/src/test/java/org/apache/kafka/metalog/LocalLogManager.java +++ b/metadata/src/test/java/org/apache/kafka/metalog/LocalLogManager.java @@ -243,11 +243,6 @@ synchronized long tryAppend(int nodeId, int epoch, LocalBatch batch) { } public synchronized long append(LocalBatch batch) { - try { - throw new RuntimeException("foo"); - } catch (Exception e) { - log.info("WATERMELON: appending {}", batch, e); - } prevOffset += batch.size(); log.debug("append(batch={}, prevOffset={})", batch, prevOffset); batches.put(prevOffset, batch);