From be8db30086d6322d1770e3b4c4bace82976df294 Mon Sep 17 00:00:00 2001
From: Neville Li <neville.lyh@gmail.com>
Date: Wed, 14 Sep 2022 17:23:31 -0400
Subject: [PATCH] Lower Kafka ConsumerConfig log level

---
 .../main/java/io/trino/plugin/kafka/KafkaConsumerFactory.java | 4 ++++
 1 file changed, 4 insertions(+)

diff --git a/plugin/trino-kafka/src/main/java/io/trino/plugin/kafka/KafkaConsumerFactory.java b/plugin/trino-kafka/src/main/java/io/trino/plugin/kafka/KafkaConsumerFactory.java
index 2d5246deba2f..7cfc98168176 100644
--- a/plugin/trino-kafka/src/main/java/io/trino/plugin/kafka/KafkaConsumerFactory.java
+++ b/plugin/trino-kafka/src/main/java/io/trino/plugin/kafka/KafkaConsumerFactory.java
@@ -15,14 +15,18 @@
 package io.trino.plugin.kafka;
 
 import io.trino.spi.connector.ConnectorSession;
+import org.apache.kafka.clients.consumer.ConsumerConfig;
 import org.apache.kafka.clients.consumer.KafkaConsumer;
 
 import java.util.Properties;
+import java.util.logging.Level;
+import java.util.logging.Logger;
 
 public interface KafkaConsumerFactory
 {
     default KafkaConsumer<byte[], byte[]> create(ConnectorSession session)
     {
+        Logger.getLogger(ConsumerConfig.class.getName()).setLevel(Level.WARNING);
         return new KafkaConsumer<>(configure(session));
     }