root
/
kafka
mirror of https://github.com/apache/kafka.git
1
0
Fork 0
Code Issues Actions 4 Packages Projects Releases Wiki Activity

MINOR: Change system test console consumer default log level (#12819) 

For tests which use the console consumer service, we are currently enabling TRACE logging by default. I have seen some system tests where this produces GBs of logging. A better default is probably DEBUG.

Reviewers: José Armando García Sancio <jsancio@apache.org>
This commit is contained in:
Jason Gustafson 2022-11-07 13:42:36 -08:00 committed by GitHub
parent 4af5dae05c
commit 150a0758cb
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
1 changed files with 2 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
tests/kafkatest/services/console_consumer.py
View File

@ -65,7 +65,7 @@ class ConsoleConsumer(KafkaPathResolverMixin, JmxMixin, BackgroundThreadService)
enable_systest_events=False, stop_timeout_sec=35, print_timestamp=False, print_partition=False, enable_systest_events=False, stop_timeout_sec=35, print_timestamp=False, print_partition=False,
isolation_level="read_uncommitted", jaas_override_variables=None, isolation_level="read_uncommitted", jaas_override_variables=None,
kafka_opts_override="", client_prop_file_override="", consumer_properties={}, kafka_opts_override="", client_prop_file_override="", consumer_properties={},
wait_until_partitions_assigned=False): wait_until_partitions_assigned=False, log_level="DEBUG"):
""" """
Args: Args:
context: standard context context: standard context
@ -113,7 +113,7 @@ class ConsoleConsumer(KafkaPathResolverMixin, JmxMixin, BackgroundThreadService)
self.client_id = client_id self.client_id = client_id
self.print_key = print_key self.print_key = print_key
self.print_partition = print_partition self.print_partition = print_partition
self.log_level = "TRACE" self.log_level = log_level
self.stop_timeout_sec = stop_timeout_sec self.stop_timeout_sec = stop_timeout_sec
self.isolation_level = isolation_level self.isolation_level = isolation_level