[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/62bf0018 Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/62bf0018 Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/62bf0018 Branch: refs/heads/release-1.4 Commit: 62bf00189b136dd34c5af5d6181c33c1415f16b9 Parents: 27564c3 Author: Piotr Nowojski <[email protected]> Authored: Wed Nov 22 15:55:20 2017 +0100 Committer: Aljoscha Krettek <[email protected]> Committed: Thu Nov 23 14:45:16 2017 +0100 ---------------------------------------------------------------------- .../kafka/FlinkKafkaProducer011ITCase.java | 16 ---------------- 1 file changed, 16 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/flink/blob/62bf0018/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();
