You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by ch...@apache.org on 2018/04/06 13:23:47 UTC
[2/7] flink git commit: [hotfix][tests] Remove unused methods in
KafkaConsumerTestBase
[hotfix][tests] Remove unused methods in KafkaConsumerTestBase
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/4c337dc9
Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/4c337dc9
Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/4c337dc9
Branch: refs/heads/master
Commit: 4c337dc9a89dfb549a3c2cb62893d74129582143
Parents: cead9a9
Author: zentol <ch...@apache.org>
Authored: Tue Apr 3 11:42:43 2018 +0200
Committer: zentol <ch...@apache.org>
Committed: Fri Apr 6 15:23:01 2018 +0200
----------------------------------------------------------------------
.../connectors/kafka/KafkaConsumerTestBase.java | 26 --------------------
1 file changed, 26 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/flink/blob/4c337dc9/flink-connectors/flink-connector-kafka-base/src/test/java/org/apache/flink/streaming/connectors/kafka/KafkaConsumerTestBase.java
----------------------------------------------------------------------
diff --git a/flink-connectors/flink-connector-kafka-base/src/test/java/org/apache/flink/streaming/connectors/kafka/KafkaConsumerTestBase.java b/flink-connectors/flink-connector-kafka-base/src/test/java/org/apache/flink/streaming/connectors/kafka/KafkaConsumerTestBase.java
index f9d745e..959d6f1 100644
--- a/flink-connectors/flink-connector-kafka-base/src/test/java/org/apache/flink/streaming/connectors/kafka/KafkaConsumerTestBase.java
+++ b/flink-connectors/flink-connector-kafka-base/src/test/java/org/apache/flink/streaming/connectors/kafka/KafkaConsumerTestBase.java
@@ -2121,32 +2121,6 @@ public abstract class KafkaConsumerTestBase extends KafkaTestBase {
return result;
}
- private static void printTopic(String topicName, ConsumerConfig config,
- DeserializationSchema<?> deserializationSchema,
- int stopAfter) throws IOException {
-
- List<MessageAndMetadata<byte[], byte[]>> contents = readTopicToList(topicName, config, stopAfter);
- LOG.info("Printing contents of topic {} in consumer grouo {}", topicName, config.groupId());
-
- for (MessageAndMetadata<byte[], byte[]> message: contents) {
- Object out = deserializationSchema.deserialize(message.message());
- LOG.info("Message: partition: {} offset: {} msg: {}", message.partition(), message.offset(), out.toString());
- }
- }
-
- private static void printTopic(String topicName, int elements, DeserializationSchema<?> deserializer)
- throws IOException {
- // write the sequence to log for debugging purposes
- Properties newProps = new Properties(standardProps);
- newProps.setProperty("group.id", "topic-printer" + UUID.randomUUID().toString());
- newProps.setProperty("auto.offset.reset", "smallest");
- newProps.setProperty("zookeeper.connect", standardProps.getProperty("zookeeper.connect"));
- newProps.putAll(secureProps);
-
- ConsumerConfig printerConfig = new ConsumerConfig(newProps);
- printTopic(topicName, printerConfig, deserializer, elements);
- }
-
private static class BrokerKillingMapper<T> extends RichMapFunction<T, T>
implements ListCheckpointed<Integer>, CheckpointListener {