From c1e74ab3f3c3bb3ef3b7ec2f6fea2bcef3d92c8c Mon Sep 17 00:00:00 2001
From: rymarm <rim.maxim+dev@gmail.com>
Date: Thu, 29 Sep 2022 17:14:58 +0300
Subject: [PATCH] DRILL-8321: Change kafka_2.13 dependency scope to test

---
 contrib/storage-kafka/pom.xml                                   | 1 +
 .../java/org/apache/drill/exec/store/kafka/MessageIterator.java | 2 +-
 2 files changed, 2 insertions(+), 1 deletion(-)

diff --git a/contrib/storage-kafka/pom.xml b/contrib/storage-kafka/pom.xml
index 94dc0ae03f1..57b1f7fea21 100644
--- a/contrib/storage-kafka/pom.xml
+++ b/contrib/storage-kafka/pom.xml
@@ -81,6 +81,7 @@
       <groupId>org.apache.kafka</groupId>
       <artifactId>kafka_2.13</artifactId>
       <version>${kafka.version}</version>
+      <scope>test</scope>
       <exclusions>
         <exclusion>
           <groupId>org.slf4j</groupId>
diff --git a/contrib/storage-kafka/src/main/java/org/apache/drill/exec/store/kafka/MessageIterator.java b/contrib/storage-kafka/src/main/java/org/apache/drill/exec/store/kafka/MessageIterator.java
index 98272982577..7282147ee82 100644
--- a/contrib/storage-kafka/src/main/java/org/apache/drill/exec/store/kafka/MessageIterator.java
+++ b/contrib/storage-kafka/src/main/java/org/apache/drill/exec/store/kafka/MessageIterator.java
@@ -28,13 +28,13 @@
 import org.apache.kafka.clients.consumer.ConsumerRecord;
 import org.apache.kafka.clients.consumer.ConsumerRecords;
 import org.apache.kafka.clients.consumer.KafkaConsumer;
+import org.apache.kafka.common.KafkaException;
 import org.apache.kafka.common.TopicPartition;
 import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;
 
 import org.apache.drill.shaded.guava.com.google.common.base.Stopwatch;
 
-import kafka.common.KafkaException;
 
 public class MessageIterator implements Iterator<ConsumerRecord<byte[], byte[]>>, AutoCloseable {