Repository: flink
Updated Branches:
  refs/heads/release-1.5 ff3a0ec69 -> 0ec37e44c


[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/69b8a920
Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/69b8a920
Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/69b8a920

Branch: refs/heads/release-1.5
Commit: 69b8a920b3fbb1969269b335dd4633d780f3468c
Parents: f4e0cdf
Author: zentol <ches...@apache.org>
Authored: Tue Apr 3 11:42:43 2018 +0200
Committer: zentol <ches...@apache.org>
Committed: Fri Apr 6 15:24:02 2018 +0200

----------------------------------------------------------------------
 .../connectors/kafka/KafkaConsumerTestBase.java | 26 --------------------
 1 file changed, 26 deletions(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/flink/blob/69b8a920/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 {
 

Reply via email to