commit | b0b1ff8d6577f16f51776d2cc407080a8ec7ccb4 | [log] [tgz] |
---|---|---|
author | Jia Zhai <zhaijia@apache.org> | Sun Aug 18 15:39:37 2019 +0800 |
committer | Sijie Guo <sijie@apache.org> | Sun Aug 18 15:39:37 2019 +0800 |
tree | 9470194f3ab5ff8129dfd2960bae299a3b3b9a14 | |
parent | d4506c97b676c82ee0c7835bba4164afef118650 [diff] |
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