pulsar-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From GitBox <...@apache.org>
Subject [GitHub] tuteng opened a new pull request #3597: [Issue 3275][pulsar-io]Support source and sink of flume
Date Thu, 14 Feb 2019 11:40:57 GMT
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:
users@infra.apache.org


With regards,
Apache Git Services

Mime
View raw message