| commit | 8fc17cff98cef3ef24e16176819d802a65dcd9fa | [log] [tgz] |
|---|---|---|
| author | lipenghui <penghui@apache.org> | Fri Apr 26 23:38:17 2019 +0800 |
| committer | Sijie Guo <sijie@apache.org> | Fri Apr 26 23:38:17 2019 +0800 |
| tree | 38ecff49065211bee1de8ae59a3e10efeec23ead | |
| parent | 6b2be1a2d447bd1ac1b4e88e0f2c0508cac8a92d [diff] |
[pulsar-flink] Add subscription initial position (#4129) ### Motivation Allow user to specify the initial position for consumer source builder. ### Modifications Add initial position for PulsarConsumerSource.