Index of /libs-snapshot-local/org/springframework/cloud/stream/app

Name Last Modified Size Description
Parent Directory
aggregate-counter-app-dependencies    
aggregate-counter-app-starters-build    
aggregate-counter-app-starters-test-support    
aggregate-counter-sink-kafka    
aggregate-counter-sink-kafka-09    
aggregate-counter-sink-kafka-10    
aggregate-counter-sink-rabbit    
aggregator-app-dependencies    
aggregator-app-starters-build    
aggregator-kafka-09    
aggregator-kafka-10    
aggregator-processor-apps    
aggregator-processor-kafka    
aggregator-processor-kafka-09    
aggregator-processor-kafka-10    
aggregator-processor-rabbit    
aggregator-rabbit    
analytics-app-dependencies    
analytics-app-starters-build    
analytics-sink-apps    
analytics-sink-kafka    
analytics-sink-rabbit    
app-starters-annotation-common    
app-starters-build    
app-starters-common    
app-starters-common-analytics    
app-starters-core-dependencies    
app-starters-file-common    
app-starters-ftp-common    
app-starters-metadata-store-common    
app-starters-metrics-common    
app-starters-micrometer-common    
app-starters-parent    
app-starters-postprocessor-common    
app-starters-release-train-build    
app-starters-s3-common    
app-starters-script-common    
app-starters-security-common    
app-starters-sftp-common    
app-starters-task-launch-request-common    
app-starters-tcp-common    
app-starters-test-support    
app-starters-time-common    
app-starters-trigger-common    
app-starters-trigger-one-common    
app-starters-trigger-unlimited-common    
app-starters-twitter-common    
apps    
aws-s3-app-dependencies    
aws-s3-app-starters-build    
aws-s3-app-starters-common    
bridge-app-dependencies    
bridge-app-starters-build    
bridge-processor    
bridge-processor-apps    
bridge-processor-kafka    
bridge-processor-kafka-09    
bridge-processor-kafka-10    
bridge-processor-rabbit    
cassandra-app-dependencies    
cassandra-app-starters-build    
cassandra-sink-apps    
cassandra-sink-kafka    
cassandra-sink-kafka-09    
cassandra-sink-kafka-10    
cassandra-sink-rabbit    
cdc-debezium-app-dependencies    
cdc-debezium-app-starters-build    
cdc-debezium-app-starters-test-support    
cdc-debezium-source-apps    
cdc-debezium-source-kafka    
cdc-debezium-source-rabbit    
cdc-debezium-spring-boot-starter    
counter-app-dependencies    
counter-app-starters-build    
counter-processor-kafka    
counter-processor-rabbit    
counter-sink-apps    
counter-sink-kafka    
counter-sink-kafka-09    
counter-sink-kafka-10    
counter-sink-rabbit    
cq-gemfire-source-kafka    
cq-gemfire-source-rabbit    
debezium-source-kafka    
debezium-source-rabbit    
elasticsearch-sink-apps    
elasticsearch-sink-kafka    
elasticsearch-sink-rabbit    
field-value-counter-app-dependencies    
field-value-counter-app-starters-build    
field-value-counter-app-starters-test-support    
field-value-counter-sink-kafka    
field-value-counter-sink-kafka-09    
field-value-counter-sink-kafka-10    
field-value-counter-sink-rabbit    
file-app-dependencies    
file-app-generator    
file-app-starters-build    
file-sink-apps    
file-sink-kafka    
file-sink-kafka-09    
file-sink-kafka-10    
file-sink-rabbit    
file-source-apps    
file-source-kafka    
file-source-kafka-09    
file-source-kafka-10    
file-source-rabbit    
filter-app-dependencies    
filter-app-starters-build    
filter-processor    
filter-processor-apps    
filter-processor-kafka    
filter-processor-kafka-09    
filter-processor-kafka-10    
filter-processor-rabbit    
ftp-app-dependencies    
ftp-app-starters-build    
ftp-app-starters-test-support    
ftp-sink-apps    
ftp-sink-kafka    
ftp-sink-kafka-09    
ftp-sink-kafka-10    
ftp-sink-rabbit    
ftp-source-apps    
ftp-source-kafka    
ftp-source-kafka-09    
ftp-source-kafka-10    
ftp-source-rabbit    
function-app-rabbit    
funtion-app-starters-build    
gemfire-app-dependencies    
gemfire-app-starters-build    
gemfire-app-starters-test-support    
gemfire-cq-source-kafka    
gemfire-cq-source-kafka-09    
gemfire-cq-source-kafka-10    
gemfire-cq-source-rabbit    
gemfire-sink-kafka    
gemfire-sink-kafka-09    
gemfire-sink-kafka-10    
gemfire-sink-rabbit    
gemfire-source-kafka    
gemfire-source-kafka-09    
gemfire-source-kafka-10    
gemfire-source-rabbit    
geode-sink-apps    
geode-sink-kafka    
geode-sink-rabbit    
geode-source-apps    
geode-source-kafka    
geode-source-rabbit    
gpfdist-app-dependencies    
gpfdist-app-starters-build    
gpfdist-sink-kafka    
gpfdist-sink-kafka-09    
gpfdist-sink-kafka-10    
gpfdist-sink-rabbit    
groovy-filter-app-dependencies    
groovy-filter-app-starters-build    
groovy-filter-processor-kafka    
groovy-filter-processor-kafka-09    
groovy-filter-processor-kafka-10    
groovy-filter-processor-rabbit    
groovy-processor    
groovy-processor-apps    
groovy-processor-kafka    
groovy-processor-rabbit    
groovy-transform-app-dependencies    
groovy-transform-app-starters-build    
groovy-transform-processor    
groovy-transform-processor-apps    
groovy-transform-processor-kafka    
groovy-transform-processor-kafka-09    
groovy-transform-processor-kafka-10    
groovy-transform-processor-rabbit    
grpc-app-dependencies    
grpc-app-protos    
grpc-app-starters-build    
grpc-app-test-support    
grpc-processor-kafka    
grpc-processor-rabbit    
hdfs-app-dependencies    
hdfs-app-starters-build    
hdfs-dataset-sink-kafka    
hdfs-dataset-sink-kafka-09    
hdfs-dataset-sink-kafka-10    
hdfs-dataset-sink-rabbit    
hdfs-sink-kafka    
hdfs-sink-kafka-09    
hdfs-sink-kafka-10    
hdfs-sink-rabbit    
header-enricher-app-dependencies    
header-enricher-app-starters-build    
header-enricher-processor-apps    
header-enricher-processor-kafka    
header-enricher-processor-kafka-09    
header-enricher-processor-kafka-10    
header-enricher-processor-rabbit    
header-filter-processor-kafka    
header-filter-processor-rabbit    
http-app-dependencies    
http-app-generator    
http-app-starters-build    
http-request-processor    
http-request-processor-apps    
http-request-processor-kafka    
http-request-processor-rabbit    
http-source-apps    
http-source-apps-generator    
http-source-kafka    
http-source-kafka-09    
http-source-kafka-10    
http-source-rabbit    
httpclient-app-dependencies    
httpclient-app-starters-build    
httpclient-app-starters-test-support    
httpclient-processor-kafka    
httpclient-processor-kafka-09    
httpclient-processor-kafka-10    
httpclient-processor-rabbit    
https-source    
https-source-kafka    
https-source-rabbit    
image-recognition-processor    
image-recognition-processor-apps    
image-recognition-processor-kafka    
image-recognition-processor-rabbit    
integration-test-processor-kafka    
integration-test-processor-rabbit    
jdbc-app-dependencies    
jdbc-app-starters-build    
jdbc-app-starters-common    
jdbc-sink-apps    
jdbc-sink-kafka    
jdbc-sink-kafka-09    
jdbc-sink-kafka-10    
jdbc-sink-rabbit    
jdbc-source-apps    
jdbc-source-apps-generator    
jdbc-source-kafka    
jdbc-source-kafka-09    
jdbc-source-kafka-10    
jdbc-source-rabbit    
jms-app-dependencies    
jms-app-starters-build    
jms-app-starters-test-support    
jms-source-apps    
jms-source-kafka    
jms-source-kafka-09    
jms-source-kafka-10    
jms-source-rabbit    
kafka-sink-kafka    
kafka-sink-rabbit    
kafka-source-kafka    
kafka-source-rabbit    
load-generator-app-dependencies    
load-generator-app-starters-build    
load-generator-app-starters-test-support    
load-generator-source    
load-generator-source-apps    
load-generator-source-kafka    
load-generator-source-kafka-09    
load-generator-source-kafka-10    
load-generator-source-rabbit    
log-app-dependencies    
log-app-generator    
log-app-starters-build    
log-sink-apps    
log-sink-kafka    
log-sink-kafka-09    
log-sink-kafka-10    
log-sink-rabbit    
loggregator-app-dependencies    
loggregator-app-starters-build    
loggregator-app-starters-test-support    
loggregator-source-kafka    
loggregator-source-kafka-09    
loggregator-source-kafka-10    
loggregator-source-rabbit    
mail-app-dependencies    
mail-app-starters-build    
mail-app-starters-test-support    
mail-source-apps    
mail-source-kafka    
mail-source-kafka-09    
mail-source-kafka-10    
mail-source-rabbit    
mongodb-app-dependencies    
mongodb-app-starters-build    
mongodb-sink-apps    
mongodb-sink-kafka    
mongodb-sink-kafka-09    
mongodb-sink-kafka-10    
mongodb-sink-rabbit    
mongodb-source-apps    
mongodb-source-kafka    
mongodb-source-kafka-09    
mongodb-source-kafka-10    
mongodb-source-rabbit    
mqtt-app-dependencies    
mqtt-app-starters-build    
mqtt-app-starters-common    
mqtt-app-starters-test-support    
mqtt-sink-apps    
mqtt-sink-kafka    
mqtt-sink-rabbit    
mqtt-source-apps    
mqtt-source-kafka    
mqtt-source-rabbit    
object-detection-processor    
object-detection-processor-apps    
object-detection-processor-kafka    
object-detection-processor-rabbit    
pgcopy-sink    
pgcopy-sink-apps    
pgcopy-sink-kafka    
pgcopy-sink-kafka-09    
pgcopy-sink-kafka-10    
pgcopy-sink-rabbit    
plugin    
pmml-app-dependencies    
pmml-app-starters-build    
pmml-app-starters-test-support    
pmml-processor-kafka    
pmml-processor-kafka-09    
pmml-processor-kafka-10    
pmml-processor-rabbit    
rabbit-app-dependencies    
rabbit-app-starters-build    
rabbit-app-starters-test-support    
rabbit-sink-apps    
rabbit-sink-kafka    
rabbit-sink-kafka-09    
rabbit-sink-kafka-10    
rabbit-sink-rabbit    
rabbit-source-apps    
rabbit-source-kafka    
rabbit-source-kafka-09    
rabbit-source-kafka-10    
rabbit-source-rabbit    
redis-app-dependencies    
redis-app-starters-build    
redis-app-starters-test-support    
redis-pubsub-app-dependencies    
redis-sink-apps    
redis-sink-kafka    
redis-sink-kafka-09    
redis-sink-kafka-10    
redis-sink-rabbit    
release-train    
router-app-dependencies    
router-app-starters-build    
router-sink    
router-sink-apps    
router-sink-kafka    
router-sink-kafka-09    
router-sink-kafka-10    
router-sink-rabbit    
rsocket-sink-apps    
rsocket-sink-kafka    
rsocket-sink-rabbit    
s3-sink-apps    
s3-sink-kafka    
s3-sink-kafka-09    
s3-sink-kafka-10    
s3-sink-rabbit    
s3-source-apps    
s3-source-kafka    
s3-source-kafka-09    
s3-source-kafka-10    
s3-source-rabbit    
script-processor    
script-processor-apps    
script-processor-kafka    
script-processor-rabbit    
scriptable-transform-app-dependencies    
scriptable-transform-app-starters-build    
scriptable-transform-processor-kafka    
scriptable-transform-processor-kafka-09    
scriptable-transform-processor-kafka-10    
scriptable-transform-processor-rabbit    
semantic-segmentation-processor    
semantic-segmentation-processor-apps    
semantic-segmentation-processor-kafka    
semantic-segmentation-processor-rabbit    
sftp-app-dependencies    
sftp-app-starters-build    
sftp-app-starters-common    
sftp-app-starters-test-support    
sftp-sink-apps    
sftp-sink-kafka    
sftp-sink-kafka-09    
sftp-sink-kafka-10    
sftp-sink-rabbit    
sftp-source-apps    
sftp-source-kafka    
sftp-source-kafka-09    
sftp-source-kafka-10    
sftp-source-rabbit    
splitter-app-dependencies    
splitter-app-starters-build    
splitter-processor-apps    
splitter-processor-kafka    
splitter-processor-kafka-09    
splitter-processor-kafka-10    
splitter-processor-rabbit    
spring-cloud-starter-stream-aggregator    
spring-cloud-starter-stream-app-function    
spring-cloud-starter-stream-aws-integration-tests    
spring-cloud-starter-stream-common-analytics    
spring-cloud-starter-stream-common-cdc-debezium    
spring-cloud-starter-stream-common-cdc-debezium-core    
spring-cloud-starter-stream-common-gemfire    
spring-cloud-starter-stream-common-shell    
spring-cloud-starter-stream-common-tensorflow    
spring-cloud-starter-stream-hdfs    
spring-cloud-starter-stream-processor-aggregator    
spring-cloud-starter-stream-processor-bridge    
spring-cloud-starter-stream-processor-counter    
spring-cloud-starter-stream-processor-filter    
spring-cloud-starter-stream-processor-groovy-filter    
spring-cloud-starter-stream-processor-groovy-transform    
spring-cloud-starter-stream-processor-grpc    
spring-cloud-starter-stream-processor-header-enricher    
spring-cloud-starter-stream-processor-httpclient    
spring-cloud-starter-stream-processor-image-recognition    
spring-cloud-starter-stream-processor-integration-test    
spring-cloud-starter-stream-processor-object-detection    
spring-cloud-starter-stream-processor-pmml    
spring-cloud-starter-stream-processor-pose-estimation    
spring-cloud-starter-stream-processor-python-http    
spring-cloud-starter-stream-processor-python-jython    
spring-cloud-starter-stream-processor-scriptable-transform    
spring-cloud-starter-stream-processor-splitter    
spring-cloud-starter-stream-processor-tasklaunchrequest-transform    
spring-cloud-starter-stream-processor-tcp-client    
spring-cloud-starter-stream-processor-tensorflow    
spring-cloud-starter-stream-processor-transform    
spring-cloud-starter-stream-processor-twitter-sentiment    
spring-cloud-starter-stream-sink-aggregate-counter    
spring-cloud-starter-stream-sink-cassandra    
spring-cloud-starter-stream-sink-counter    
spring-cloud-starter-stream-sink-dataset-hdfs    
spring-cloud-starter-stream-sink-field-value-counter    
spring-cloud-starter-stream-sink-file    
spring-cloud-starter-stream-sink-ftp    
spring-cloud-starter-stream-sink-gemfire    
spring-cloud-starter-stream-sink-gpfdist    
spring-cloud-starter-stream-sink-hdfs    
spring-cloud-starter-stream-sink-hdfs-dataset    
spring-cloud-starter-stream-sink-jdbc    
spring-cloud-starter-stream-sink-log    
spring-cloud-starter-stream-sink-mongodb    
spring-cloud-starter-stream-sink-mqtt    
spring-cloud-starter-stream-sink-pgcopy    
spring-cloud-starter-stream-sink-rabbit    
spring-cloud-starter-stream-sink-redis    
spring-cloud-starter-stream-sink-router    
spring-cloud-starter-stream-sink-s3    
spring-cloud-starter-stream-sink-sftp    
spring-cloud-starter-stream-sink-task-launcher-cloudfoundry    
spring-cloud-starter-stream-sink-task-launcher-dataflow    
spring-cloud-starter-stream-sink-task-launcher-kubernetes    
spring-cloud-starter-stream-sink-task-launcher-local    
spring-cloud-starter-stream-sink-task-launcher-yarn    
spring-cloud-starter-stream-sink-tcp    
spring-cloud-starter-stream-sink-throughput    
spring-cloud-starter-stream-sink-websocket    
spring-cloud-starter-stream-source-cdc-debezium    
spring-cloud-starter-stream-source-file    
spring-cloud-starter-stream-source-ftp    
spring-cloud-starter-stream-source-gemfire    
spring-cloud-starter-stream-source-gemfire-cq    
spring-cloud-starter-stream-source-http    
spring-cloud-starter-stream-source-jdbc    
spring-cloud-starter-stream-source-jms    
spring-cloud-starter-stream-source-load-generator    
spring-cloud-starter-stream-source-loggregator    
spring-cloud-starter-stream-source-mail    
spring-cloud-starter-stream-source-mongodb    
spring-cloud-starter-stream-source-mqtt    
spring-cloud-starter-stream-source-rabbit    
spring-cloud-starter-stream-source-s3    
spring-cloud-starter-stream-source-sftp    
spring-cloud-starter-stream-source-sftp-dataflow    
spring-cloud-starter-stream-source-syslog    
spring-cloud-starter-stream-source-tcp    
spring-cloud-starter-stream-source-tcp-client    
spring-cloud-starter-stream-source-time    
spring-cloud-starter-stream-source-trigger    
spring-cloud-starter-stream-source-triggertask    
spring-cloud-starter-stream-source-twitterstream    
spring-cloud-starter-stream-source-websocket    
spring-cloud-stream-app-core-dependencies    
spring-cloud-stream-app-dependencies    
spring-cloud-stream-app-descriptor    
spring-cloud-stream-app-generator    
spring-cloud-stream-app-starter-dependencies    
spring-cloud-stream-app-starters    
spring-cloud-stream-app-starters-core    
spring-cloud-stream-app-starters-docs    
spring-cloud-stream-app-starters-docs-parent    
spring-cloud-stream-cassandra-parent    
spring-cloud-stream-cloudfoundry-parent    
spring-cloud-stream-file-build    
spring-cloud-stream-file-parent    
spring-cloud-stream-ftp-build    
spring-cloud-stream-ftp-parent    
spring-cloud-stream-gemfire-parent    
spring-cloud-stream-gpfdist-parent    
spring-cloud-stream-hdfs-parent    
spring-cloud-stream-http-build    
spring-cloud-stream-http-parent    
spring-cloud-stream-jdbc-parent    
spring-cloud-stream-jms-parent    
spring-cloud-stream-log-build    
spring-cloud-stream-log-parent    
spring-cloud-stream-mail-parent    
spring-cloud-stream-metrics-parent    
spring-cloud-stream-mongodb-parent    
spring-cloud-stream-processor-parent    
spring-cloud-stream-rabbit-parent    
spring-cloud-stream-redis-parent    
spring-cloud-stream-router-parent    
spring-cloud-stream-s3-parent    
spring-cloud-stream-sftp-parent    
spring-cloud-stream-syslog-parent    
spring-cloud-stream-tasklauncher-parent    
spring-cloud-stream-tcp-parent    
spring-cloud-stream-testing-parent    
spring-cloud-stream-time-build    
spring-cloud-stream-time-parent    
spring-cloud-stream-trigger-parent    
spring-cloud-stream-triggertask-parent    
spring-cloud-stream-twitter-parent    
spring-cloud-stream-websocket-parent    
starter-parent    
stream-applications-build    
stream-applications-composite-function-support    
stream-applications-core    
stream-applications-descriptor    
stream-applications-docs    
stream-applications-metadata-store-common    
stream-applications-micrometer-common    
stream-applications-postprocessor-common    
stream-applications-release-train    
stream-applications-security-common    
stream-applications-task-launch-request-common    
stream-applications-test-support    
stream-apps-annotation-common    
stream-apps-common    
stream-apps-file-common    
stream-apps-ftp-common    
stream-apps-metadata-store-common    
stream-apps-micrometer-common    
stream-apps-parent    
stream-apps-postprocessor-common    
stream-apps-release-train    
stream-apps-security-common    
stream-apps-task-launch-request-common    
stream-apps-test-support    
stream-apps-time-common    
stream-apps-trigger-common    
stream-apps-trigger-one-common    
stream-apps-trigger-unlimited-common    
syslog-app-dependencies    
syslog-app-starters-build    
syslog-source-apps    
syslog-source-kafka    
syslog-source-kafka-09    
syslog-source-kafka-10    
syslog-source-rabbit    
task-launcher-cloudfoundry-sink-kafka    
task-launcher-cloudfoundry-sink-kafka-09    
task-launcher-cloudfoundry-sink-kafka-10    
task-launcher-cloudfoundry-sink-rabbit    
task-launcher-local-sink-kafka    
task-launcher-local-sink-kafka-09    
task-launcher-local-sink-kafka-10    
task-launcher-local-sink-rabbit    
task-launcher-yarn-sink-kafka    
task-launcher-yarn-sink-kafka-09    
task-launcher-yarn-sink-kafka-10    
task-launcher-yarn-sink-rabbit    
tasklauncher-cloudfoundry-app-dependencies    
tasklauncher-cloudfoundry-app-starters-build    
tasklauncher-local-app-dependencies    
tasklauncher-local-app-starters-build    
tasklauncher-sink    
tasklauncher-sink-apps    
tasklauncher-sink-kafka    
tasklauncher-sink-rabbit    
tasklauncher-yarn-app-dependencies    
tasklauncher-yarn-app-starters-build    
tasklaunchrequest-transform-app-dependencies    
tasklaunchrequest-transform-app-starters-build    
tasklaunchrequest-transform-processor-kafka    
tasklaunchrequest-transform-processor-kafka-09    
tasklaunchrequest-transform-processor-kafka-10    
tasklaunchrequest-transform-processor-rabbit    
tcp-app-dependencies    
tcp-app-starters-build    
tcp-app-starters-common    
tcp-app-starters-test-support    
tcp-client-processor-kafka    
tcp-client-processor-kafka-09    
tcp-client-processor-kafka-10    
tcp-client-processor-rabbit    
tcp-client-source-kafka    
tcp-client-source-kafka-09    
tcp-client-source-kafka-10    
tcp-client-source-rabbit    
tcp-sink-apps    
tcp-sink-kafka    
tcp-sink-kafka-09    
tcp-sink-kafka-10    
tcp-sink-rabbit    
tcp-source-apps    
tcp-source-kafka    
tcp-source-kafka-09    
tcp-source-kafka-10    
tcp-source-rabbit    
tensorflow-processor-kafka    
tensorflow-processor-rabbit    
throughput-app-dependencies    
throughput-app-starters-build    
throughput-sink    
throughput-sink-apps    
throughput-sink-kafka    
throughput-sink-kafka-09    
throughput-sink-kafka-10    
throughput-sink-rabbit    
time-app-dependencies    
time-app-generator    
time-app-starters-build    
time-source-apps    
time-source-kafka    
time-source-kafka-09    
time-source-kafka-10    
time-source-rabbit    
transform-app-dependencies    
transform-app-starters-build    
transform-processor-apps    
transform-processor-kafka    
transform-processor-kafka-09    
transform-processor-kafka-10    
transform-processor-rabbit    
trigger-app-dependencies    
trigger-app-starters-build    
trigger-source-kafka    
trigger-source-kafka-09    
trigger-source-kafka-10    
trigger-source-rabbit    
triggertask-app-dependencies    
triggertask-app-starters-build    
triggertask-source-kafka    
triggertask-source-kafka-09    
triggertask-source-kafka-10    
triggertask-source-rabbit    
twitter-app-dependencies    
twitter-message-sink-apps    
twitter-message-sink-kafka    
twitter-message-sink-rabbit    
twitter-message-source-apps    
twitter-message-source-kafka    
twitter-message-source-rabbit    
twitter-search-source-apps    
twitter-search-source-kafka    
twitter-search-source-rabbit    
twitter-stream-source-apps    
twitter-stream-source-kafka    
twitter-stream-source-rabbit    
twitter-trend-processor-apps    
twitter-trend-processor-kafka    
twitter-trend-processor-rabbit    
twitter-update-sink-apps    
twitter-update-sink-kafka    
twitter-update-sink-rabbit    
twitterstream-app-dependencies    
twitterstream-app-starters-build    
twitterstream-app-starters-common    
twitterstream-app-starters-test-support    
twitterstream-source-kafka    
twitterstream-source-kafka-09    
twitterstream-source-kafka-10    
twitterstream-source-rabbit    
wavefront-sink-apps    
wavefront-sink-kafka    
wavefront-sink-rabbit    
websocket-app-dependencies    
websocket-app-starters-build    
websocket-sink-apps    
websocket-sink-kafka    
websocket-sink-kafka-09    
websocket-sink-kafka-10    
websocket-sink-rabbit    
websocket-source-apps    
websocket-source-kafka    
websocket-source-rabbit    
xmpp-sink-kafka    
xmpp-sink-rabbit    
xmpp-source-kafka    
xmpp-source-rabbit    
zeromq-sink-apps    
zeromq-sink-kafka    
zeromq-sink-rabbit    
zeromq-source-apps    
zeromq-source-kafka    
zeromq-source-rabbit