You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@kafka.apache.org by gu...@apache.org on 2017/09/05 23:09:19 UTC
kafka git commit: HOTFIX: remove unused imports
Repository: kafka
Updated Branches:
refs/heads/0.11.0 426057094 -> fc3eeb004
HOTFIX: remove unused imports
Project: http://git-wip-us.apache.org/repos/asf/kafka/repo
Commit: http://git-wip-us.apache.org/repos/asf/kafka/commit/fc3eeb00
Tree: http://git-wip-us.apache.org/repos/asf/kafka/tree/fc3eeb00
Diff: http://git-wip-us.apache.org/repos/asf/kafka/diff/fc3eeb00
Branch: refs/heads/0.11.0
Commit: fc3eeb00473bd3a27517c8e047defbbe28905375
Parents: 4260570
Author: Guozhang Wang <wa...@gmail.com>
Authored: Tue Sep 5 16:09:10 2017 -0700
Committer: Guozhang Wang <wa...@gmail.com>
Committed: Tue Sep 5 16:09:10 2017 -0700
----------------------------------------------------------------------
.../apache/kafka/streams/processor/internals/StreamThreadTest.java | 1 -
1 file changed, 1 deletion(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/kafka/blob/fc3eeb00/streams/src/test/java/org/apache/kafka/streams/processor/internals/StreamThreadTest.java
----------------------------------------------------------------------
diff --git a/streams/src/test/java/org/apache/kafka/streams/processor/internals/StreamThreadTest.java b/streams/src/test/java/org/apache/kafka/streams/processor/internals/StreamThreadTest.java
index b13613a..9209b56 100644
--- a/streams/src/test/java/org/apache/kafka/streams/processor/internals/StreamThreadTest.java
+++ b/streams/src/test/java/org/apache/kafka/streams/processor/internals/StreamThreadTest.java
@@ -28,7 +28,6 @@ import org.apache.kafka.common.Cluster;
import org.apache.kafka.common.Node;
import org.apache.kafka.common.PartitionInfo;
import org.apache.kafka.common.TopicPartition;
-import org.apache.kafka.common.errors.ProducerFencedException;
import org.apache.kafka.common.metrics.Metrics;
import org.apache.kafka.common.utils.MockTime;
import org.apache.kafka.common.utils.Time;