commit 1142d7ad1fa765afce400c64a4ab944b9be761a4
author tuteng <eguangning@gmail.com> Mon Mar 04 17:17:22 2019 +0800
committer Jia Zhai <zhaijia@apache.org> Mon Mar 04 17:17:22 2019 +0800
tree c750036b1d95f8e69622d49216467ac0861f0094
parent 7c826ead862930ceeb71cba2b4040294cdc23cfc

[Issue 3275][pulsar-io]Support source and sink of flume (#3597)

* Support TLS authentication and authorization in standalone mode

* Compile success
To do: test channel, sink and source of flume

* Add conf file

* Add sink and source folder
Move file to folder
Add source
Compile success
To do -> test source

* test flume source paas

* Add config file and test case

* Add test and update pom.xml
To do add test of source and sink

* Add unit tests

* Add test case and test pass
To do test source

* Add license
Add test source of pulsar

* Handle if blockingQueue is null

* Move LOG to log

* Format code

* Add sinkClass in pulsar-io.yaml

* Add comment

* Default is false

* Modify pom file of flume

* Format pom.xml file

* Move pom version to 2.4.0-SNAPSHOT