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 create(ConnectorSession session) { + Logger.getLogger(ConsumerConfig.class.getName()).setLevel(Level.WARNING); return new KafkaConsumer<>(configure(session)); }