Repository: flink Updated Branches: refs/heads/master ccf917de2 -> 458c909ca
[hotfix][kafka] Remove unused method in kafka tests Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/458c909c Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/458c909c Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/458c909c Branch: refs/heads/master Commit: 458c909caf6f3ab1a6ed90c2508eacf686d1d101 Parents: f214e7d Author: Piotr Nowojski <piotr.nowoj...@gmail.com> Authored: Wed Nov 22 15:55:20 2017 +0100 Committer: Aljoscha Krettek <aljoscha.kret...@gmail.com> Committed: Thu Nov 23 14:44:18 2017 +0100 ---------------------------------------------------------------------- .../kafka/FlinkKafkaProducer011ITCase.java | 16 ---------------- 1 file changed, 16 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/flink/blob/458c909c/flink-connectors/flink-connector-kafka-0.11/src/test/java/org/apache/flink/streaming/connectors/kafka/FlinkKafkaProducer011ITCase.java ---------------------------------------------------------------------- diff --git a/flink-connectors/flink-connector-kafka-0.11/src/test/java/org/apache/flink/streaming/connectors/kafka/FlinkKafkaProducer011ITCase.java b/flink-connectors/flink-connector-kafka-0.11/src/test/java/org/apache/flink/streaming/connectors/kafka/FlinkKafkaProducer011ITCase.java index a32c7f8..85735c8 100644 --- a/flink-connectors/flink-connector-kafka-0.11/src/test/java/org/apache/flink/streaming/connectors/kafka/FlinkKafkaProducer011ITCase.java +++ b/flink-connectors/flink-connector-kafka-0.11/src/test/java/org/apache/flink/streaming/connectors/kafka/FlinkKafkaProducer011ITCase.java @@ -29,12 +29,7 @@ import org.apache.flink.streaming.util.OneInputStreamOperatorTestHarness; import org.apache.flink.streaming.util.serialization.KeyedSerializationSchema; import org.apache.flink.streaming.util.serialization.KeyedSerializationSchemaWrapper; -import org.apache.flink.shaded.guava18.com.google.common.collect.Iterables; - import kafka.server.KafkaServer; -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.errors.ProducerFencedException; import org.junit.Before; import org.junit.Test; @@ -553,17 +548,6 @@ public class FlinkKafkaProducer011ITCase extends KafkaTestBase { } } - private void assertRecord(String topicName, String expectedKey, String expectedValue) { - try (KafkaConsumer<String, String> kafkaConsumer = new KafkaConsumer<>(extraProperties)) { - kafkaConsumer.subscribe(Collections.singletonList(topicName)); - ConsumerRecords<String, String> records = kafkaConsumer.poll(10000); - - ConsumerRecord<String, String> record = Iterables.getOnlyElement(records); - assertEquals(expectedKey, record.key()); - assertEquals(expectedValue, record.value()); - } - } - private void closeIgnoringProducerFenced(AutoCloseable autoCloseable) throws Exception { try { autoCloseable.close();
