Skip to content

Commit

Permalink
[FLINK-36278] Reduce Kafka log level
Browse files Browse the repository at this point in the history
Reduce the information that Kafka consumer and producer is logging + Kafka server for old school tests.
  • Loading branch information
AHeise committed Sep 23, 2024
1 parent 2f86484 commit ec8d7c2
Show file tree
Hide file tree
Showing 2 changed files with 6 additions and 8 deletions.
10 changes: 2 additions & 8 deletions flink-connector-kafka/src/test/resources/log4j2-test.properties
Original file line number Diff line number Diff line change
Expand Up @@ -27,15 +27,9 @@ appender.testlogger.target = SYSTEM_ERR
appender.testlogger.layout.type = PatternLayout
appender.testlogger.layout.pattern = %-4r [%t] %-5p %c %x - %m%n

logger.kafka.name = kafka
# Kafka producer and consumer level
logger.kafka.name = org.apache.kafka
logger.kafka.level = OFF
logger.kafka2.name = state.change
logger.kafka2.level = OFF

logger.zookeeper.name = org.apache.zookeeper
logger.zookeeper.level = OFF
logger.I0Itec.name = org.I0Itec
logger.I0Itec.level = OFF

# Logger configuration for containers, by default this is off
# If you want to investigate test failures, overwrite the level as above
Expand Down
4 changes: 4 additions & 0 deletions tools/ci/log4j.properties
Original file line number Diff line number Diff line change
Expand Up @@ -38,6 +38,10 @@ appender.file.layout.type = PatternLayout
appender.file.layout.pattern = %d{HH:mm:ss,SSS} [%20t] %-5p %-60c %x - %m%n
appender.file.createOnDemand = true

# Kafka producer and consumer level
logger.kafka.name = org.apache.kafka
logger.kafka.level = OFF

# suppress the irrelevant (wrong) warnings from the netty channel handler
logger.netty.name = org.jboss.netty.channel.DefaultChannelPipeline
logger.netty.level = ERROR
Expand Down

0 comments on commit ec8d7c2

Please sign in to comment.