tuteng opened a new pull request #3597: [Issue 3275][pulsar-io]Support source 
and sink of flume
URL: https://github.com/apache/pulsar/pull/3597
 
 
   ### Motivation
   
   https://github.com/apache/pulsar/issues/3275
   
   ### Modifications
   
   - Support data of flume to pulsar
   - Support data of pulsar to flume
   
   ### Document
   ##### flow of data
   
![4](https://user-images.githubusercontent.com/1907867/52784463-34287000-3090-11e9-8eeb-a968f8626ccf.png)
   
   
   ##### sink command
   ```
   pulsar/bin/pulsar-admin sink localrun --archive 
pulsar/pulsar-io/flume/target/pulsar-io-flume-2.3.0-SNAPSHOT.nar --classname 
org.apache.pulsar.io.flume.sink.StringSink --tenant public --namespace default 
--name flume  --inputs flume_test --sink-config-file 
pulsar/pulsar-io/flume/src/main/resources/flume/flume-io-source.yaml 
--parallelism 1
   ```
   ##### source command
   ```
   pulsar/bin/pulsar-admin source localrun --archive 
pulsar/pulsar-io/flume/target/pulsar-io-flume-2.3.0-SNAPSHOT.nar --classname 
org.apache.pulsar.io.flume.source.StringSource --tenant public --namespace 
default --name flume  --destination-topic-name flume_test --source-config-file 
pulsar/pulsar-io/flume/src/main/resources/flume/flume-io-sink.yaml 
--parallelism 1
   ```
   
   ##### other document
   In editing

----------------------------------------------------------------
This is an automated message from the Apache Git Service.
To respond to the message, please log on GitHub and use the
URL above to go to the specific comment.
 
For queries about this service, please contact Infrastructure at:
[email protected]


With regards,
Apache Git Services

Reply via email to