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 {
