You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@drill.apache.org by cg...@apache.org on 2022/10/02 02:58:50 UTC
[drill] branch master updated: DRILL-8321: Change kafka_2.13 dependency scope to test (#2662)
This is an automated email from the ASF dual-hosted git repository.
cgivre pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/drill.git
The following commit(s) were added to refs/heads/master by this push:
new 88f3c684bb DRILL-8321: Change kafka_2.13 dependency scope to test (#2662)
88f3c684bb is described below
commit 88f3c684bb64385c9136ba2cf43efce9578109c1
Author: Rymar Maksym <ri...@gmail.com>
AuthorDate: Sun Oct 2 05:58:43 2022 +0300
DRILL-8321: Change kafka_2.13 dependency scope to test (#2662)
---
contrib/storage-kafka/pom.xml | 1 +
.../main/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 94dc0ae03f..57b1f7fea2 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 9827298257..7282147ee8 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.drill.exec.ExecConstants;
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 {