| commit | 3011f7eee4c114f300540d390a14e6457c34ddbd | [log] [tgz] |
|---|---|---|
| author | Sijie Guo <guosijie@gmail.com> | Tue Sep 11 12:11:41 2018 -0700 |
| committer | GitHub <noreply@github.com> | Tue Sep 11 12:11:41 2018 -0700 |
| tree | 8b04bf23b66d4d3fb478708822322a621b6473d1 | |
| parent | 5254016511bb797c480efa056f8236f5bc9623c0 [diff] |
[ecosystem] Flink pulsar source connector (#2555) *Motivation* This ports apache/flink#6200 to apache pulsar repo. It adds a pulsar source connector which will enable flink jobs to process messages from pulsar topics. *Changes* Add a PulsarConsumerSource connector