From 04b298042284f7a38bc3e866fd3f4d27e31dd21d Mon Sep 17 00:00:00 2001 From: "Matthias J. Sax" Date: Tue, 14 Apr 2020 18:35:46 -0700 Subject: [PATCH] KAFKA-9819: Fix flaky test in StoreChangelogReaderTest --- .../processor/internals/StoreChangelogReaderTest.java | 2 +- .../processor/internals/testutil/LogCaptureAppender.java | 6 ++++++ 2 files changed, 7 insertions(+), 1 deletion(-) diff --git a/streams/src/test/java/org/apache/kafka/streams/processor/internals/StoreChangelogReaderTest.java b/streams/src/test/java/org/apache/kafka/streams/processor/internals/StoreChangelogReaderTest.java index 46cbdb92d305b..9a796172698e5 100644 --- a/streams/src/test/java/org/apache/kafka/streams/processor/internals/StoreChangelogReaderTest.java +++ b/streams/src/test/java/org/apache/kafka/streams/processor/internals/StoreChangelogReaderTest.java @@ -946,8 +946,8 @@ public Map endOffsets(final Collection par @Test public void shouldNotThrowOnUnknownRevokedPartition() { - final LogCaptureAppender appender = LogCaptureAppender.createAndRegister(); LogCaptureAppender.setClassLoggerToDebug(changelogReader.getClass()); + final LogCaptureAppender appender = LogCaptureAppender.createAndRegister(changelogReader.getClass()); try { changelogReader.remove( diff --git a/streams/src/test/java/org/apache/kafka/streams/processor/internals/testutil/LogCaptureAppender.java b/streams/src/test/java/org/apache/kafka/streams/processor/internals/testutil/LogCaptureAppender.java index a1f7b3111fcdc..40c6076d01384 100644 --- a/streams/src/test/java/org/apache/kafka/streams/processor/internals/testutil/LogCaptureAppender.java +++ b/streams/src/test/java/org/apache/kafka/streams/processor/internals/testutil/LogCaptureAppender.java @@ -60,6 +60,12 @@ public static LogCaptureAppender createAndRegister() { return logCaptureAppender; } + public static LogCaptureAppender createAndRegister(final Class clazz) { + final LogCaptureAppender logCaptureAppender = new LogCaptureAppender(); + Logger.getLogger(clazz).addAppender(logCaptureAppender); + return logCaptureAppender; + } + public static void setClassLoggerToDebug(final Class clazz) { Logger.getLogger(clazz).setLevel(Level.DEBUG); }