add flink PulsarConsumerSourceTests no impl

apache · Mar 1, 2020 · f2ccfd7 · f2ccfd7
1 parent 30206f2
commit f2ccfd7
Showing 1 changed file with 32 additions and 0 deletions.
diff --git a/...src/test/java/org/apache/flink/streaming/connectors/pulsar/PulsarConsumerSourceTests.java b/...src/test/java/org/apache/flink/streaming/connectors/pulsar/PulsarConsumerSourceTests.java
@@ -566,6 +566,38 @@ public MessageId getLastMessageId() throws PulsarClientException {
         public CompletableFuture<MessageId> getLastMessageIdAsync() {
             return null;
         }
+
+        @Override
+        public void reconsumeLater(Message<?> message, long delayTime, TimeUnit unit) throws PulsarClientException {
+
+        }
+
+        @Override
+        public void reconsumeLater(Messages<?> messages, long delayTime, TimeUnit unit) throws PulsarClientException {
+
+        }
+
+        @Override
+        public void reconsumeLaterCumulative(Message<?> message, long delayTime, TimeUnit unit)
+                throws PulsarClientException {
+
+        }
+
+        @Override
+        public CompletableFuture<Void> reconsumeLaterAsync(Message<?> message, long delayTime, TimeUnit unit) {
+            return null;
+        }
+
+        @Override
+        public CompletableFuture<Void> reconsumeLaterAsync(Messages<?> messages, long delayTime, TimeUnit unit) {
+            return null;
+        }
+
+        @Override
+        public CompletableFuture<Void> reconsumeLaterCumulativeAsync(Message<?> message, long delayTime,
+                TimeUnit unit) {
+            return null;
+        }
     }
 
     private static List<Message> createMessages(int startIndex, int numMessages) {