expose getLastMessageId method in ConsumerImpl (#4911)
Fixes #4909
### Motivation
It would be good to expose method `getLastMessageId` in `ConsumerImpl` to a public method.
eg. some times user would like to know the lag messages; or only consume messages before current time.
### Modifications
- expose method `getLastMessageId` in consumer api.
- add unit test.
### Verifying this change
Ut passed
diff --git a/pulsar-flink/src/test/java/org/apache/flink/streaming/connectors/pulsar/PulsarConsumerSourceTests.java b/pulsar-flink/src/test/java/org/apache/flink/streaming/connectors/pulsar/PulsarConsumerSourceTests.java
index a666bb0..a0b9471 100644
--- a/pulsar-flink/src/test/java/org/apache/flink/streaming/connectors/pulsar/PulsarConsumerSourceTests.java
+++ b/pulsar-flink/src/test/java/org/apache/flink/streaming/connectors/pulsar/PulsarConsumerSourceTests.java
@@ -530,6 +530,16 @@
@Override
public void resume() {
}
+
+ @Override
+ public MessageId getLastMessageId() throws PulsarClientException {
+ return null;
+ }
+
+ @Override
+ public CompletableFuture<MessageId> getLastMessageIdAsync() {
+ return null;
+ }
}
private static List<Message> createMessages(int startIndex, int numMessages) {
