Skip to content

Commit ec8d7c2

Browse files
committed
[FLINK-36278] Reduce Kafka log level
Reduce the information that Kafka consumer and producer is logging + Kafka server for old school tests.
1 parent 2f86484 commit ec8d7c2

File tree

2 files changed

+6
-8
lines changed

2 files changed

+6
-8
lines changed

flink-connector-kafka/src/test/resources/log4j2-test.properties

Lines changed: 2 additions & 8 deletions
Original file line numberDiff line numberDiff line change
@@ -27,15 +27,9 @@ appender.testlogger.target = SYSTEM_ERR
2727
appender.testlogger.layout.type = PatternLayout
2828
appender.testlogger.layout.pattern = %-4r [%t] %-5p %c %x - %m%n
2929

30-
logger.kafka.name = kafka
30+
# Kafka producer and consumer level
31+
logger.kafka.name = org.apache.kafka
3132
logger.kafka.level = OFF
32-
logger.kafka2.name = state.change
33-
logger.kafka2.level = OFF
34-
35-
logger.zookeeper.name = org.apache.zookeeper
36-
logger.zookeeper.level = OFF
37-
logger.I0Itec.name = org.I0Itec
38-
logger.I0Itec.level = OFF
3933

4034
# Logger configuration for containers, by default this is off
4135
# If you want to investigate test failures, overwrite the level as above

tools/ci/log4j.properties

Lines changed: 4 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -38,6 +38,10 @@ appender.file.layout.type = PatternLayout
3838
appender.file.layout.pattern = %d{HH:mm:ss,SSS} [%20t] %-5p %-60c %x - %m%n
3939
appender.file.createOnDemand = true
4040

41+
# Kafka producer and consumer level
42+
logger.kafka.name = org.apache.kafka
43+
logger.kafka.level = OFF
44+
4145
# suppress the irrelevant (wrong) warnings from the netty channel handler
4246
logger.netty.name = org.jboss.netty.channel.DefaultChannelPipeline
4347
logger.netty.level = ERROR

0 commit comments

Comments
 (0)