You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@kafka.apache.org by rh...@apache.org on 2019/08/25 22:08:45 UTC

[kafka] branch 1.0 updated: MINOR: Correct build error on missing import from previous merge

This is an automated email from the ASF dual-hosted git repository.

rhauch pushed a commit to branch 1.0
in repository https://gitbox.apache.org/repos/asf/kafka.git


The following commit(s) were added to refs/heads/1.0 by this push:
     new 3377c8e  MINOR: Correct build error on missing import from previous merge
3377c8e is described below

commit 3377c8e86989ac5a7a40e586565bfec72511df54
Author: Randall Hauch <rh...@gmail.com>
AuthorDate: Sun Aug 25 17:09:07 2019 -0500

    MINOR: Correct build error on missing import from previous merge
---
 .../src/main/java/org/apache/kafka/connect/runtime/WorkerSourceTask.java | 1 +
 1 file changed, 1 insertion(+)

diff --git a/connect/runtime/src/main/java/org/apache/kafka/connect/runtime/WorkerSourceTask.java b/connect/runtime/src/main/java/org/apache/kafka/connect/runtime/WorkerSourceTask.java
index d0257b9..e90a490 100644
--- a/connect/runtime/src/main/java/org/apache/kafka/connect/runtime/WorkerSourceTask.java
+++ b/connect/runtime/src/main/java/org/apache/kafka/connect/runtime/WorkerSourceTask.java
@@ -29,6 +29,7 @@ import org.apache.kafka.common.metrics.stats.Total;
 import org.apache.kafka.common.metrics.stats.Value;
 import org.apache.kafka.common.utils.Time;
 import org.apache.kafka.connect.errors.ConnectException;
+import org.apache.kafka.connect.errors.RetriableException;
 import org.apache.kafka.connect.runtime.ConnectMetrics.MetricGroup;
 import org.apache.kafka.connect.source.SourceRecord;
 import org.apache.kafka.connect.source.SourceTask;