You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by al...@apache.org on 2017/11/23 13:45:43 UTC
[3/3] flink git commit: [hotfix][kafka] Remove unused method in kafka
tests
[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 <pi...@gmail.com>
Authored: Wed Nov 22 15:55:20 2017 +0100
Committer: Aljoscha Krettek <al...@gmail.com>
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();