Skip to content

Commit ba71727

Browse files
authored
Update LogAccessor instantiations with current class names (#3603)
1 parent be76cc3 commit ba71727

File tree

3 files changed

+8
-3
lines changed

3 files changed

+8
-3
lines changed

spring-kafka-test/src/main/java/org/springframework/kafka/test/EmbeddedKafkaZKBroker.java

Lines changed: 2 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -88,12 +88,13 @@
8888
* @author Adrian Chlebosz
8989
* @author Soby Chacko
9090
* @author Sanghyeok An
91+
* @author Borahm Lee
9192
*
9293
* @since 2.2
9394
*/
9495
public class EmbeddedKafkaZKBroker implements EmbeddedKafkaBroker {
9596

96-
private static final LogAccessor logger = new LogAccessor(LogFactory.getLog(EmbeddedKafkaBroker.class)); // NOSONAR
97+
private static final LogAccessor logger = new LogAccessor(LogFactory.getLog(EmbeddedKafkaZKBroker.class)); // NOSONAR
9798

9899
public static final String SPRING_EMBEDDED_ZOOKEEPER_CONNECT = "spring.embedded.zookeeper.connect";
99100

spring-kafka/src/main/java/org/springframework/kafka/listener/ContainerPartitionPausingBackOffManager.java

Lines changed: 2 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -32,12 +32,13 @@
3232
*
3333
* @author Tomaz Fernandes
3434
* @author Gary Russell
35+
* @author Borahm Lee
3536
* @since 2.9
3637
* @see DefaultErrorHandler
3738
*/
3839
public class ContainerPartitionPausingBackOffManager implements KafkaConsumerBackoffManager {
3940

40-
private static final LogAccessor LOGGER = new LogAccessor(LogFactory.getLog(KafkaConsumerBackoffManager.class));
41+
private static final LogAccessor LOGGER = new LogAccessor(LogFactory.getLog(ContainerPartitionPausingBackOffManager.class));
4142

4243
private final ListenerContainerRegistry listenerContainerRegistry;
4344

spring-kafka/src/main/java/org/springframework/kafka/support/serializer/DelegatingByTopicSerialization.java

Lines changed: 4 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -25,6 +25,8 @@
2525
import java.util.concurrent.ConcurrentHashMap;
2626
import java.util.regex.Pattern;
2727

28+
import org.apache.commons.logging.LogFactory;
29+
2830
import org.springframework.core.log.LogAccessor;
2931
import org.springframework.lang.NonNull;
3032
import org.springframework.lang.Nullable;
@@ -40,6 +42,7 @@
4042
* @author Gary Russell
4143
* @author Wang Zhiyang
4244
* @author Sanghyeok An
45+
* @author Borahm Lee
4346
*
4447
* @since 2.8
4548
*
@@ -48,7 +51,7 @@ public abstract class DelegatingByTopicSerialization<T extends Closeable> implem
4851

4952
private static final String UNCHECKED = "unchecked";
5053

51-
private static final LogAccessor LOGGER = new LogAccessor(DelegatingDeserializer.class);
54+
private static final LogAccessor LOGGER = new LogAccessor(LogFactory.getLog(DelegatingByTopicSerialization.class));
5255

5356
/**
5457
* Name of the configuration property containing the serialization selector map for

0 commit comments

Comments
 (0)