This is an automated email from the ASF dual-hosted git repository. dzamo pushed a commit to branch 1.20 in repository https://gitbox.apache.org/repos/asf/drill.git
commit 7400628512099df77e1382db5da2121ab61d386a Author: Rymar Maksym <[email protected]> AuthorDate: Sun Oct 2 05:58:43 2022 +0300 DRILL-8321: Change kafka_2.13 dependency scope to test (#2662) (cherry picked from commit 88f3c684bb64385c9136ba2cf43efce9578109c1) --- 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 c4e021cf5f..4e12a11dd1 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 {
