diff --git a/spring-kafka-test/src/main/java/org/springframework/kafka/test/EmbeddedKafkaZKBroker.java b/spring-kafka-test/src/main/java/org/springframework/kafka/test/EmbeddedKafkaZKBroker.java
index 00c0551348..a4e3761acd 100644
--- a/spring-kafka-test/src/main/java/org/springframework/kafka/test/EmbeddedKafkaZKBroker.java
+++ b/spring-kafka-test/src/main/java/org/springframework/kafka/test/EmbeddedKafkaZKBroker.java
@@ -88,12 +88,13 @@
  * @author Adrian Chlebosz
  * @author Soby Chacko
  * @author Sanghyeok An
+ * @author Borahm Lee
  *
  * @since 2.2
  */
 public class EmbeddedKafkaZKBroker implements EmbeddedKafkaBroker {
 
-	private static final LogAccessor logger = new LogAccessor(LogFactory.getLog(EmbeddedKafkaBroker.class)); // NOSONAR
+	private static final LogAccessor logger = new LogAccessor(LogFactory.getLog(EmbeddedKafkaZKBroker.class)); // NOSONAR
 
 	public static final String SPRING_EMBEDDED_ZOOKEEPER_CONNECT = "spring.embedded.zookeeper.connect";
 
diff --git a/spring-kafka/src/main/java/org/springframework/kafka/listener/ContainerPartitionPausingBackOffManager.java b/spring-kafka/src/main/java/org/springframework/kafka/listener/ContainerPartitionPausingBackOffManager.java
index 4b9889afe6..8782290b30 100644
--- a/spring-kafka/src/main/java/org/springframework/kafka/listener/ContainerPartitionPausingBackOffManager.java
+++ b/spring-kafka/src/main/java/org/springframework/kafka/listener/ContainerPartitionPausingBackOffManager.java
@@ -32,12 +32,13 @@
  *
  * @author Tomaz Fernandes
  * @author Gary Russell
+ * @author Borahm Lee
  * @since 2.9
  * @see DefaultErrorHandler
  */
 public class ContainerPartitionPausingBackOffManager implements KafkaConsumerBackoffManager {
 
-	private static final LogAccessor LOGGER = new LogAccessor(LogFactory.getLog(KafkaConsumerBackoffManager.class));
+	private static final LogAccessor LOGGER = new LogAccessor(LogFactory.getLog(ContainerPartitionPausingBackOffManager.class));
 
 	private final ListenerContainerRegistry listenerContainerRegistry;
 
diff --git a/spring-kafka/src/main/java/org/springframework/kafka/support/serializer/DelegatingByTopicSerialization.java b/spring-kafka/src/main/java/org/springframework/kafka/support/serializer/DelegatingByTopicSerialization.java
index 851a1e9067..54e44c8e99 100644
--- a/spring-kafka/src/main/java/org/springframework/kafka/support/serializer/DelegatingByTopicSerialization.java
+++ b/spring-kafka/src/main/java/org/springframework/kafka/support/serializer/DelegatingByTopicSerialization.java
@@ -25,6 +25,8 @@
 import java.util.concurrent.ConcurrentHashMap;
 import java.util.regex.Pattern;
 
+import org.apache.commons.logging.LogFactory;
+
 import org.springframework.core.log.LogAccessor;
 import org.springframework.lang.NonNull;
 import org.springframework.lang.Nullable;
@@ -40,6 +42,7 @@
  * @author Gary Russell
  * @author Wang Zhiyang
  * @author Sanghyeok An
+ * @author Borahm Lee
  *
  * @since 2.8
  *
@@ -48,7 +51,7 @@ public abstract class DelegatingByTopicSerialization<T extends Closeable> implem
 
 	private static final String UNCHECKED = "unchecked";
 
-	private static final LogAccessor LOGGER = new LogAccessor(DelegatingDeserializer.class);
+	private static final LogAccessor LOGGER = new LogAccessor(LogFactory.getLog(DelegatingByTopicSerialization.class));
 
 	/**
 	 * Name of the configuration property containing the serialization selector map for