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<TopicPartition, Long> endOffsets(final Collection<TopicPartition> 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);
     }