SpringCloud/stream-applications
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

Update versions

Browse Source 
Docs/Descriptor metadata updates
This commit is contained in:
Soby Chacko
2020-06-23 19:02:07 -04:00
parent 873f17414e
commit bd48ead4e6
17 changed files with 241 additions and 71 deletions
Download Patch File Download Diff File Expand all files Collapse all files

81
README.adoc
View File

@@ -24,42 +24,51 @@ The following are the four major components of this repository.
|link:functions/supplier/file-supplier/README.adoc[File]
|link:functions/consumer/cassandra-consumer/README.adoc[Cassandra]
|link:functions/function/filter-function/README.adoc[Filter]
|link:functions/supplier/http-supplier/README.adoc[HTTP]
|link:functions/supplier/ftp-supplier/README.adoc[FTP]
|link:functions/consumer/counter-consumer/README.adoc[Counter]
|link:functions/function/header-enricher-function/README.adoc[Header-Enricher]
|link:functions/supplier/jdbc-supplier/README.adoc[JDBC]
|link:functions/supplier/geode-supplier/README.adoc[Geode]
|link:functions/consumer/file-consumer/README.adoc[File]
|link:functions/function/http-request-function/README.adoc[HTTP Request]
|link:functions/supplier/geode-supplier/README.adoc[Geode]
|link:functions/consumer/geode-consumer/README.adoc[Geode]
|
|link:functions/supplier/mongodb-supplier/README.adoc[MongoDB]
|link:functions/supplier/http-supplier/README.adoc[HTTP]
|link:functions/consumer/ftp-consumer/README.adoc[FTP]
|
|link:functions/supplier/jdbc-supplier/README.adoc[JDBC]
|link:functions/consumer/geode-consumer/README.adoc[Geode]
|link:functions/function/spel-function/README.adoc[SpEL]
|link:functions/supplier/mqtt-supplier/README.adoc[MQTT]
|link:functions/supplier/jms-supplier/README.adoc[JMS]
|link:functions/consumer/jdbc-consumer/README.adoc[JDBC]
|link:functions/function/splitter-function/README.adoc[Splitter]
|link:functions/supplier/tcp-supplier/README.adoc[TCP]
|link:functions/supplier/mongodb-supplier/README.adoc[MongoDB]
|link:functions/consumer/log-consumer/README.adoc[Log]
|
|link:functions/supplier/time-supplier/README.adoc[Time]
|link:functions/function/task-launch-request-function/README.adoc[Task Launch Request]
|link:functions/supplier/mqtt-supplier/README.adoc[MQTT]
|link:functions/consumer/mongodb-consumer/README.adoc[MongoDB]
|
|
|link:functions/function/tasklauncher-function/README.adoc[Task Launcher]
|link:functions/supplier/rabbit-supplier/README.adoc[RabbitMQ]
|link:functions/consumer/mqtt-consumer/README.adoc[MQTT]
|link:functions/function/twitter-function/README.adoc[Twitter]
|link:functions/supplier/s3-supplier/README.adoc[AWS S3]
|link:functions/consumer/rabbit-consumer/README.adoc[RabbitMQ]
|
|
|link:functions/consumer/rabbit-consumer/README.adoc[Rabbit]
|
|
|link:functions/supplier/tcp-supplier/README.adoc[TCP]
|link:functions/consumer/redis-consumer/README.adoc[Redis]
|
|link:functions/supplier/time-supplier/README.adoc[Time]
|link:functions/consumer/s3-consumer/README.adoc[AWS S3]
|
|link:functions/supplier/twitter-supplier/README.adoc[Twitter]
|link:functions/consumer/sftp-consumer/README.adoc[SFTP]
|
|
|link:functions/supplier/websocket-supplier/README.adoc[Websocket]
|link:functions/consumer/tcp-consumer/README.adoc[TCP]
|
|
|link:functions/consumer/twitter-consumer/README.adoc[Twitter]
|
|
|link:functions/consumer/websocket-consumer/README.adoc[Websocker]
|
|===
=== Available Spring Cloud Stream Applications
@@ -70,48 +79,56 @@ The following are the four major components of this repository.
|link:applications/source/file-source/README.adoc[File]
|link:applications/sink/cassandra-sink/README.adoc[Cassandra]
|link:applications/processor/bridge-processor/README.adoc[Bridge]
|link:applications/source/geode-source/README.adoc[Geode]
|link:applications/source/ftp-source/README.adoc[FTP]
|link:applications/sink/counter-sink/README.adoc[Counter]
|link:applications/processor/filter-processor/README.adoc[Filter]
|link:applications/source/http-source/README.adoc[HTTP]
|link:applications/source/geode-source/README.adoc[Geode]
|link:applications/sink/file-sink/README.adoc[Fiile]
|link:applications/processor/groovy-processor/README.adoc[Groovy]
|link:applications/source/jdbc-source/README.adoc[JDBC]
|link:applications/source/http-source/README.adoc[HTTP]
|link:applications/sink/ftp-sink/README.adoc[FTP]
|link:applications/processor/header-enricher-processor/README.adoc[Header-Enricher]
|link:applications/source/load-generator-source/README.adoc[Load-Generator]
|link:applications/source/jdbc-source/README.adoc[JDBC]
|link:applications/sink/geode-sink/README.adoc[Geode]
|link:applications/processor/http-request-processor/README.adoc[HTTP Request]
|link:applications/source/mongodb-source/README.adoc[MongoDB]
|link:applications/source/jms-source/README.adoc[JMS]
|link:applications/sink/jdbc-sink/README.adoc[JDBC]
|link:applications/processor/script-processor/README.adoc[Script]
|link:applications/source/mqtt-source/README.adoc[MQTT]
|link:applications/source/load-generator-source/README.adoc[Load-Generator]
|link:applications/sink/log-sink/README.adoc[Log]
|link:applications/processor/splitter-processor/README.adoc[Splitter]
|link:applications/source/rabbit-source/README.adoc[Rabbit]
|link:applications/source/mongodb-source/README.adoc[MongoDB]
|link:applications/sink/mongodb-sink/README.adoc[MongoDB]
|link:applications/processor/transform-processor/README.adoc[Transform]
|link:applications/source/tcp-source/README.adoc[TCP]
|link:applications/source/mqtt-source/README.adoc[MQTT]
|link:applications/sink/mqtt-sink/README.adoc[MQTT]
|link:applications/processor/twitter-trend-processor/README.adoc[Twitter Trend]
|link:applications/source/rabbit-source/README.adoc[RabbitMQ]
|link:applications/sink/rabbit-sink/README.adoc[RabbitMQ]
|
|link:applications/source/time-source/README.adoc[Time]
|link:applications/sink/rabbit-sink/README.adoc[Rabbit]
|
|
|link:applications/source/s3-source/README.adoc[AWS S3]
|link:applications/sink/redis-sink/README.adoc[Redis]
|
|
|link:applications/source/tcp-source/README.adoc[TCP]
|link:applications/sink/router-sink/README.adoc[Router]
|
|
|link:applications/source/time-source/README.adoc[Time]
|link:applications/sink/sftp-sink/README.adoc[SFTP]
|
|link:applications/source/twitter-message-source/README.adoc[Twitter Message]
|link:applications/sink/tasklauncher-sink/README.adoc[Task Launcher]
|
|link:applications/source/twitter-search-source/README.adoc[Twitter Search]
|link:applications/sink/tcp-sink/README.adoc[TCP]
|
|
|link:applications/source/twitter-stream-source/README.adoc[Twitter Stream]
|link:applications/sink/throughput-sink/README.adoc[Throughput]
|
|link:applications/source/websocket-source/README.adoc[Websocket]
|link:applications/sink/twitter-message-sink/README.adoc[Twitter Message]
|
|
|link:applications/sink/twitter-update-sink/README.adoc[Twitter Update]
|
|===

10
applications/stream-applications-build/pom.xml
View File

@@ -29,8 +29,12 @@
<mongodb-source.version>3.0.0-SNAPSHOT</mongodb-source.version>
<mqtt-source.version>3.0.0-SNAPSHOT</mqtt-source.version>
<rabbit-source.version>3.0.0-SNAPSHOT</rabbit-source.version>
<s3-source.version>3.0.0-SNAPSHOT</s3-source.version>
<tcp-source.version>3.0.0-SNAPSHOT</tcp-source.version>
<time-source.version>3.0.0-SNAPSHOT</time-source.version>
<twitter-message-source.version>3.0.0-SNAPSHOT</twitter-message-source.version>
<twitter-search-source.version>3.0.0-SNAPSHOT</twitter-search-source.version>
<twitter-stream-source.version>3.0.0-SNAPSHOT</twitter-stream-source.version>
<websocket-source.version>3.0.0-SNAPSHOT</websocket-source.version>
<cassandra-sink.version>3.0.0-SNAPSHOT</cassandra-sink.version>
<counter-sink.version>3.0.0-SNAPSHOT</counter-sink.version>
@@ -44,10 +48,13 @@
<rabbit-sink.version>3.0.0-SNAPSHOT</rabbit-sink.version>
<redis-sink.version>3.0.0-SNAPSHOT</redis-sink.version>
<router-sink.version>3.0.0-SNAPSHOT</router-sink.version>
<s3-sink.version>3.0.0-SNAPSHOT</s3-sink.version>
<sftp-sink.version>3.0.0-SNAPSHOT</sftp-sink.version>
<tcp-sink.version>3.0.0-SNAPSHOT</tcp-sink.version>
<tasklauncher-sink.version>3.0.0-SNAPSHOT</tasklauncher-sink.version>
<tcp-sink.version>3.0.0-SNAPSHOT</tcp-sink.version>
<throughput-sink.version>3.0.0-SNAPSHOT</throughput-sink.version>
<twitter-message-sink.version>3.0.0-SNAPSHOT</twitter-message-sink.version>
<twitter-update-sink.version>3.0.0-SNAPSHOT</twitter-update-sink.version>
<websocket-sink.version>3.0.0-SNAPSHOT</websocket-sink.version>
<bridge-processor.version>3.0.0-SNAPSHOT</bridge-processor.version>
<filter-processor.version>3.0.0-SNAPSHOT</filter-processor.version>
@@ -57,6 +64,7 @@
<script-processor.version>3.0.0-SNAPSHOT</script-processor.version>
<splitter-processor.version>3.0.0-SNAPSHOT</splitter-processor.version>
<transform-processor.version>3.0.0-SNAPSHOT</transform-processor.version>
<twitter-trend-processor.version>3.0.0-SNAPSHOT</twitter-trend-processor.version>
</properties>
<profiles>

22
applications/stream-applications-build/stream-applications-descriptor/pom.xml
View File

@@ -63,10 +63,18 @@
"${mqtt-source.version}".contains('SNAPSHOT') ? 'latest' : "${mqtt-source.version}"
pom.properties['rabbit-source-docker.tag']=
"${rabbit-source.version}".contains('SNAPSHOT') ? 'latest' : "${rabbit-source.version}"
pom.properties['s3-source-docker.tag']=
"${s3-source.version}".contains('SNAPSHOT') ? 'latest' : "${s3-source.version}"
pom.properties['tcp-source-docker.tag']=
"${tcp-source.version}".contains('SNAPSHOT') ? 'latest' : "${tcp-source.version}"
pom.properties['time-source-docker.tag']=
"${time-source.version}".contains('SNAPSHOT') ? 'latest' : "${time-source.version}"
pom.properties['twitter-message-source-docker.tag']=
"${twitter-message-source.version}".contains('SNAPSHOT') ? 'latest' : "${twitter-message-source.version}"
pom.properties['twitter-search-source-docker.tag']=
"${twitter-search-source.version}".contains('SNAPSHOT') ? 'latest' : "${twitter-search-source.version}"
pom.properties['twitter-stream-source-docker.tag']=
"${twitter-stream-source.version}".contains('SNAPSHOT') ? 'latest' : "${twitter-stream-source.version}"
pom.properties['websocket-source-docker.tag']=
"${websocket-source.version}".contains('SNAPSHOT') ? 'latest' : "${websocket-source.version}"
pom.properties['cassandra-sink-docker.tag']=
@@ -93,14 +101,20 @@
"${redis-sink.version}".contains('SNAPSHOT') ? 'latest' : "${redis-sink.version}"
pom.properties['router-sink-docker.tag']=
"${router-sink.version}".contains('SNAPSHOT') ? 'latest' : "${router-sink.version}"
pom.properties['s3-sink-docker.tag']=
"${s3-sink.version}".contains('SNAPSHOT') ? 'latest' : "${s3-sink.version}"
pom.properties['sftp-sink-docker.tag']=
"${sftp-sink.version}".contains('SNAPSHOT') ? 'latest' : "${sftp-sink.version}"
pom.properties['tasklauncher-sink-docker.tag']=
"${tasklauncher-sink.version}".contains('SNAPSHOT') ? 'latest' : "${tasklauncher-sink.version}"
pom.properties['tcp-sink-docker.tag']=
"${tcp-sink.version}".contains('SNAPSHOT') ? 'latest' : "${tcp-sink.version}"
pom.properties['throughput-sink-docker.tag']=
"${throughput-sink.version}".contains('SNAPSHOT') ? 'latest' : "${throughput-sink.version}"
pom.properties['tasklauncher-sink-docker.tag']=
"${tasklauncher-sink.version}".contains('SNAPSHOT') ? 'latest' : "${tasklauncher-sink.version}"
pom.properties['twitter-message-sink-docker.tag']=
"${twitter-message-sink.version}".contains('SNAPSHOT') ? 'latest' : "${twitter-message-sink.version}"
pom.properties['twitter-update-sink-docker.tag']=
"${twitter-update-sink.version}".contains('SNAPSHOT') ? 'latest' : "${twitter-update-sink.version}"
pom.properties['websocket-sink-docker.tag']=
"${websocket-sink.version}".contains('SNAPSHOT') ? 'latest' : "${websocket-sink.version}"
pom.properties['bridge-processor-docker.tag']=
@@ -109,8 +123,6 @@
"${filter-processor.version}".contains('SNAPSHOT') ? 'latest' : "${filter-processor.version}"
pom.properties['groovy-processor-docker.tag']=
"${groovy-processor.version}".contains('SNAPSHOT') ? 'latest' : "${groovy-processor.version}"
pom.properties['groovy-processor-docker.tag']=
"${groovy-processor.version}".contains('SNAPSHOT') ? 'latest' : "${groovy-processor.version}"
pom.properties['header-enricher-processor-docker.tag']=
"${header-enricher-processor.version}".contains('SNAPSHOT') ? 'latest' : "${header-enricher-processor.version}"
pom.properties['http-request-processor-docker.tag']=
@@ -121,6 +133,8 @@
"${splitter-processor.version}".contains('SNAPSHOT') ? 'latest' : "${splitter-processor.version}"
pom.properties['transform-processor-docker.tag']=
"${transform-processor.version}".contains('SNAPSHOT') ? 'latest' : "${transform-processor.version}"
pom.properties['twitter-trend-processor-docker.tag']=
"${twitter-trend-processor.version}".contains('SNAPSHOT') ? 'latest' : "${twitter-trend-processor.version}"
]]></source>
</configuration>
</execution>

10
applications/stream-applications-build/stream-applications-descriptor/src/main/resources/META-INF/kafka-apps-docker.properties
View File

@@ -8,8 +8,12 @@ source.load-generator=docker:springcloudstream/load-generator-source-kafka:@load
source.mongodb=docker:springcloudstream/mongodb-source-kafka:@mongodb-source-docker.tag@
source.mqtt=docker:springcloudstream/mqtt-source-kafka:@mqtt-source-docker.tag@
source.rabbit=docker:springcloudstream/rabbit-source-kafka:@rabbit-source-docker.tag@
source.s3=docker:springcloudstream/s3-source-kafka:@s3-source-docker.tag@
source.tcp=docker:springcloudstream/tcp-source-kafka:@tcp-source-docker.tag@
source.time=docker:springcloudstream/time-source-kafka:@time-source-docker.tag@
source.twitter-message=docker:springcloudstream/twitter-message-source-kafka:@twitter-message-source-docker.tag@
source.twitter-search=docker:springcloudstream/twitter-search-source-kafka:@twitter-search-source-docker.tag@
source.twitter-stream=docker:springcloudstream/twitter-stream-source-kafka:@twitter-stream-source-docker.tag@
source.websocket=docker:springcloudstream/websocket-source-kafka:@websocket-source-docker.tag@
sink.cassandra=docker:springcloudstream/cassandra-sink-kafka:@cassandra-sink-docker.tag@
sink.counter=docker:springcloudstream/counter-sink-kafka:@counter-sink-docker.tag@
@@ -23,10 +27,13 @@ sink.mqtt=docker:springcloudstream/mqtt-sink-kafka:@mqtt-sink-docker.tag@
sink.rabbit=docker:springcloudstream/rabbit-sink-kafka:@rabbit-sink-docker.tag@
sink.redis=docker:springcloudstream/redis-sink-kafka:@redis-sink-docker.tag@
sink.router=docker:springcloudstream/router-sink-kafka:@router-sink-docker.tag@
sink.s3=docker:springcloudstream/s3-sink-kafka:@s3-sink-docker.tag@
sink.sftp=docker:springcloudstream/sftp-sink-kafka:@sftp-sink-docker.tag@
sink.tcp=docker:springcloudstream/tcp-sink-kafka:@tcp-sink-docker.tag@
sink.tasklauncher=docker:springcloudstream/tasklauncher-sink-kafka:@tasklauncher-sink-docker.tag@
sink.tcp=docker:springcloudstream/tcp-sink-kafka:@tcp-sink-docker.tag@
sink.throughput=docker:springcloudstream/throughput-sink-kafka:@throughput-sink-docker.tag@
sink.twitter-message=docker:springcloudstream/twitter-message-sink-kafka:@twitter-message-sink-docker.tag@
sink.twitter-update=docker:springcloudstream/twitter-update-sink-kafka:@twitter-update-sink-docker.tag@
sink.websocket=docker:springcloudstream/websocket-sink-kafka:@websocket-sink-docker.tag@
processor.bridge=docker:springcloudstream/bridge-processor-kafka:@bridge-processor-docker.tag@
processor.filter=docker:springcloudstream/filter-processor-kafka:@filter-processor-docker.tag@
@@ -36,3 +43,4 @@ processor.http-request=docker:springcloudstream/http-request-processor-kafka:@ht
processor.script=docker:springcloudstream/script-processor-kafka:@script-processor-docker.tag@
processor.splitter=docker:springcloudstream/splitter-processor-kafka:@splitter-processor-docker.tag@
processor.transform=docker:springcloudstream/transform-processor-kafka:@transform-processor-docker.tag@
processor.twitter-trend=docker:springcloudstream/twitter-trend-processor-kafka:@twitter-trend-processor-docker.tag@

22
applications/stream-applications-build/stream-applications-descriptor/src/main/resources/META-INF/kafka-apps-maven-repo-url.properties
View File

@@ -18,10 +18,18 @@ source.mqtt=https://@repo-spring-io@/org/springframework/cloud/stream/app/mqtt-s
source.mqtt.metadata=https://@repo-spring-io@/org/springframework/cloud/stream/app/mqtt-source-kafka/@mqtt-source.version@/mqtt-source-kafka-@mqtt-source.version@-metadata.jar
source.rabbit=https://@repo-spring-io@/org/springframework/cloud/stream/app/rabbit-source-kafka/@rabbit-source.version@/rabbit-source-kafka-@rabbit-source.version@.jar
source.rabbit.metadata=https://@repo-spring-io@/org/springframework/cloud/stream/app/rabbit-source-kafka/@rabbit-source.version@/rabbit-source-kafka-@rabbit-source.version@-metadata.jar
source.s3=https://@repo-spring-io@/org/springframework/cloud/stream/app/s3-source-kafka/@s3-source.version@/s3-source-kafka-@s3-source.version@.jar
source.s3.metadata=https://@repo-spring-io@/org/springframework/cloud/stream/app/s3-source-kafka/@s3-source.version@/s3-source-kafka-@s3-source.version@-metadata.jar
source.tcp=https://@repo-spring-io@/org/springframework/cloud/stream/app/tcp-source-kafka/@tcp-source.version@/tcp-source-kafka-@tcp-source.version@.jar
source.tcp.metadata=https://@repo-spring-io@/org/springframework/cloud/stream/app/tcp-source-kafka/@tcp-source.version@/tcp-source-kafka-@tcp-source.version@-metadata.jar
source.time=https://@repo-spring-io@/org/springframework/cloud/stream/app/time-source-kafka/@time-source.version@/time-source-kafka-@time-source.version@.jar
source.time.metadata=https://@repo-spring-io@/org/springframework/cloud/stream/app/time-source-kafka/@time-source.version@/time-source-kafka-@time-source.version@-metadata.jar
source.twitter-message=https://@repo-spring-io@/org/springframework/cloud/stream/app/twitter-message-source-kafka/@twitter-message-source.version@/twitter-message-source-kafka-@twitter-message-source.version@.jar
source.twitter-message.metadata=https://@repo-spring-io@/org/springframework/cloud/stream/app/twitter-message-source-kafka/@twitter-message-source.version@/twitter-message-source-kafka-@twitter-message-source.version@-metadata.jar
source.twitter-search=https://@repo-spring-io@/org/springframework/cloud/stream/app/twitter-search-source-kafka/@twitter-search-source.version@/twitter-search-source-kafka-@twitter-search-source.version@.jar
source.twitter-search.metadata=https://@repo-spring-io@/org/springframework/cloud/stream/app/twitter-search-source-kafka/@twitter-search-source.version@/twitter-search-source-kafka-@twitter-search-source.version@-metadata.jar
source.twitter-stream=https://@repo-spring-io@/org/springframework/cloud/stream/app/twitter-stream-source-kafka/@twitter-stream-source.version@/twitter-stream-source-kafka-@twitter-stream-source.version@.jar
source.twitter-stream.metadata=https://@repo-spring-io@/org/springframework/cloud/stream/app/twitter-stream-source-kafka/@twitter-stream-source.version@/twitter-stream-source-kafka-@twitter-stream-source.version@-metadata.jar
source.websocket=https://@repo-spring-io@/org/springframework/cloud/stream/app/websocket-source-kafka/@websocket-source.version@/websocket-source-kafka-@websocket-source.version@.jar
source.websocket.metadata=https://@repo-spring-io@/org/springframework/cloud/stream/app/websocket-source-kafka/@websocket-source.version@/websocket-source-kafka-@websocket-source.version@-metadata.jar
sink.cassandra=https://@repo-spring-io@/org/springframework/cloud/stream/app/cassandra-sink-kafka/@cassandra-sink.version@/cassandra-sink-kafka-@cassandra-sink.version@.jar
@@ -48,14 +56,20 @@ sink.redis=https://@repo-spring-io@/org/springframework/cloud/stream/app/redis-s
sink.redis.metadata=https://@repo-spring-io@/org/springframework/cloud/stream/app/redis-sink-kafka/@redis-sink.version@/redis-sink-kafka-@redis-sink.version@-metadata.jar
sink.router=https://@repo-spring-io@/org/springframework/cloud/stream/app/router-sink-kafka/@router-sink.version@/router-sink-kafka-@router-sink.version@.jar
sink.router.metadata=https://@repo-spring-io@/org/springframework/cloud/stream/app/router-sink-kafka/@router-sink.version@/router-sink-kafka-@router-sink.version@-metadata.jar
sink.s3=https://@repo-spring-io@/org/springframework/cloud/stream/app/s3-sink-kafka/@s3-sink.version@/s3-sink-kafka-@s3-sink.version@.jar
sink.s3.metadata=https://@repo-spring-io@/org/springframework/cloud/stream/app/s3-sink-kafka/@s3-sink.version@/s3-sink-kafka-@s3-sink.version@-metadata.jar
sink.sftp=https://@repo-spring-io@/org/springframework/cloud/stream/app/sftp-sink-kafka/@sftp-sink.version@/sftp-sink-kafka-@sftp-sink.version@.jar
sink.sftp.metadata=https://@repo-spring-io@/org/springframework/cloud/stream/app/sftp-sink-kafka/@sftp-sink.version@/sftp-sink-kafka-@sftp-sink.version@-metadata.jar
sink.tcp=https://@repo-spring-io@/org/springframework/cloud/stream/app/tcp-sink-kafka/@tcp-sink.version@/tcp-sink-kafka-@sftp-sink.version@.jar
sink.tcp.metadata=https://@repo-spring-io@/org/springframework/cloud/stream/app/tcp-sink-kafka/@tcp-sink.version@/tcp-sink-kafka-@tcp-sink.version@-metadata.jar
sink.tasklauncher=https://@repo-spring-io@/org/springframework/cloud/stream/app/tasklauncher-sink-kafka/@tasklauncher-sink.version@/tasklauncher-sink-kafka-@tasklauncher-sink.version@.jar
sink.tasklauncher.metadata=https://@repo-spring-io@/org/springframework/cloud/stream/app/tasklauncher-sink-kafka/@tasklauncher-sink.version@/tasklauncher-sink-kafka-@tasklauncher-sink.version@-metadata.jar
sink.tcp=https://@repo-spring-io@/org/springframework/cloud/stream/app/tcp-sink-kafka/@tcp-sink.version@/tcp-sink-kafka-@tcp-sink.version@.jar
sink.tcp.metadata=https://@repo-spring-io@/org/springframework/cloud/stream/app/tcp-sink-kafka/@tcp-sink.version@/tcp-sink-kafka-@tcp-sink.version@-metadata.jar
sink.throughput=https://@repo-spring-io@/org/springframework/cloud/stream/app/throughput-sink-kafka/@throughput-sink.version@/throughput-sink-kafka-@throughput-sink.version@.jar
sink.throughput.metadata=https://@repo-spring-io@/org/springframework/cloud/stream/app/throughput-sink-kafka/@throughput-sink.version@/throughput-sink-kafka-@throughput-sink.version@-metadata.jar
sink.twitter-message=https://@repo-spring-io@/org/springframework/cloud/stream/app/twitter-message-sink-kafka/@twitter-message-sink.version@/twitter-message-sink-kafka-@twitter-message-sink.version@.jar
sink.twitter-message.metadata=https://@repo-spring-io@/org/springframework/cloud/stream/app/twitter-message-sink-kafka/@twitter-message-sink.version@/twitter-message-sink-kafka-@twitter-message-sink.version@-metadata.jar
sink.twitter-update=https://@repo-spring-io@/org/springframework/cloud/stream/app/twitter-update-sink-kafka/@twitter-update-sink.version@/twitter-update-sink-kafka-@twitter-update-sink.version@.jar
sink.twitter-update.metadata=https://@repo-spring-io@/org/springframework/cloud/stream/app/twitter-update-sink-kafka/@twitter-update-sink.version@/twitter-update-sink-kafka-@twitter-update-sink.version@-metadata.jar
sink.websocket=https://@repo-spring-io@/org/springframework/cloud/stream/app/websocket-sink-kafka/@websocket-sink.version@/websocket-sink-kafka-@websocket-sink.version@.jar
sink.websocket.metadata=https://@repo-spring-io@/org/springframework/cloud/stream/app/websocket-sink-kafka/@websocket-sink.version@/websocket-sink-kafka-@websocket-sink.version@-metadata.jar
processor.bridge=https://@repo-spring-io@/org/springframework/cloud/stream/app/bridge-processor-kafka/@bridge-processor.version@/bridge-processor-kafka-@bridge-processor.version@.jar
@@ -73,4 +87,6 @@ processor.script.metadata=https://@repo-spring-io@/org/springframework/cloud/str
processor.splitter=https://@repo-spring-io@/org/springframework/cloud/stream/app/splitter-processor-kafka/@splitter-processor.version@/splitter-processor-kafka-@splitter-processor.version@.jar
processor.splitter.metadata=https://@repo-spring-io@/org/springframework/cloud/stream/app/splitter-processor-kafka/@splitter-processor.version@/splitter-processor-kafka-@splitter-processor.version@-metadata.jar
processor.transform=https://@repo-spring-io@/org/springframework/cloud/stream/app/transform-processor-kafka/@transform-processor.version@/transform-processor-kafka-@transform-processor.version@.jar
processor.transform.metadata=https://@repo-spring-io@/org/springframework/cloud/stream/app/transform-processor-kafka/@transform-processor.version@/transform-processor-kafka-@transform-processor.version@-metadata.jar
processor.transform.metadata=https://@repo-spring-io@/org/springframework/cloud/stream/app/transform-processor-kafka/@transform-processor.version@/transform-processor-kafka-@transform-processor.version@-metadata.jar
processor.twitter-trend=https://@repo-spring-io@/org/springframework/cloud/stream/app/twitter-trend-processor-kafka/@twitter-trend-processor.version@/twitter-trend-processor-kafka-@twitter-trend-processor.version@.jar
processor.twitter-trend.metadata=https://@repo-spring-io@/org/springframework/cloud/stream/app/twitter-trend-processor-kafka/@twitter-trend-processor.version@/twitter-trend-processor-kafka-@twitter-trend-processor.version@-metadata.jar

20
applications/stream-applications-build/stream-applications-descriptor/src/main/resources/META-INF/kafka-apps-maven.properties
View File

@@ -18,10 +18,18 @@ source.mqtt=maven://org.springframework.cloud.stream.app:mqtt-source-kafka:@mqtt
source.mqtt.metadata=maven://org.springframework.cloud.stream.app:mqtt-source-kafka:jar:metadata:@mqtt-source.version@
source.rabbit=maven://org.springframework.cloud.stream.app:rabbit-source-kafka:@rabbit-source.version@
source.rabbit.metadata=maven://org.springframework.cloud.stream.app:rabbit-source-kafka:jar:metadata:@rabbit-source.version@
source.s3=maven://org.springframework.cloud.stream.app:s3-source-kafka:@s3-source.version@
source.s3.metadata=maven://org.springframework.cloud.stream.app:s3-source-kafka:jar:metadata:@s3-source.version@
source.tcp=maven://org.springframework.cloud.stream.app:tcp-source-kafka:@tcp-source.version@
source.tcp.metadata=maven://org.springframework.cloud.stream.app:tcp-source-kafka:jar:metadata:@tcp-source.version@
source.time=maven://org.springframework.cloud.stream.app:time-source-kafka:@time-source.version@
source.time.metadata=maven://org.springframework.cloud.stream.app:time-source-kafka:jar:metadata:@time-source.version@
source.twitter-message=maven://org.springframework.cloud.stream.app:twitter-message-source-kafka:@twitter-message-source.version@
source.twitter-message.metadata=maven://org.springframework.cloud.stream.app:twitter-message-source-kafka:jar:metadata:@twitter-message-source.version@
source.twitter-search=maven://org.springframework.cloud.stream.app:twitter-search-source-kafka:@twitter-search-source.version@
source.twitter-search.metadata=maven://org.springframework.cloud.stream.app:twitter-search-source-kafka:jar:metadata:@twitter-search-source.version@
source.twitter-stream=maven://org.springframework.cloud.stream.app:twitter-stream-source-kafka:@twitter-stream-source.version@
source.twitter-stream.metadata=maven://org.springframework.cloud.stream.app:twitter-stream-source-kafka:jar:metadata:@twitter-stream-source.version@
source.websocket=maven://org.springframework.cloud.stream.app:websocket-source-kafka:@websocket-source.version@
source.websocket.metadata=maven://org.springframework.cloud.stream.app:websocket-source-kafka:jar:metadata:@websocket-source.version@
sink.cassandra=maven://org.springframework.cloud.stream.app:cassandra-sink-kafka:@cassandra-sink.version@
@@ -48,14 +56,20 @@ sink.redis=maven://org.springframework.cloud.stream.app:redis-sink-kafka:@redis-
sink.redis.metadata=maven://org.springframework.cloud.stream.app:redis-sink-kafka:jar:metadata:@redis-sink.version@
sink.router=maven://org.springframework.cloud.stream.app:router-sink-kafka:@router-sink.version@
sink.router.metadata=maven://org.springframework.cloud.stream.app:router-sink-kafka:jar:metadata:@router-sink.version@
sink.s3=maven://org.springframework.cloud.stream.app:s3-sink-kafka:@s3-sink.version@
sink.s3.metadata=maven://org.springframework.cloud.stream.app:s3-sink-kafka:jar:metadata:@s3-sink.version@
sink.sftp=maven://org.springframework.cloud.stream.app:sftp-sink-kafka:@sftp-sink.version@
sink.sftp.metadata=maven://org.springframework.cloud.stream.app:sftp-sink-kafka:jar:metadata:@sftp-sink.version@
sink.tcp=maven://org.springframework.cloud.stream.app:tcp-sink-kafka:@tcp-sink.version@
sink.tcp.metadata=maven://org.springframework.cloud.stream.app:tcp-sink-kafka:jar:metadata:@tcp-sink.version@
sink.tasklauncher=maven://org.springframework.cloud.stream.app:tasklauncher-sink-kafka:@tasklauncher-sink.version@
sink.tasklauncher.metadata=maven://org.springframework.cloud.stream.app:tasklauncher-sink-kafka:jar:metadata:@tasklauncher-sink.version@
sink.tcp=maven://org.springframework.cloud.stream.app:tcp-sink-kafka:@tcp-sink.version@
sink.tcp.metadata=maven://org.springframework.cloud.stream.app:tcp-sink-kafka:jar:metadata:@tcp-sink.version@
sink.throughput=maven://org.springframework.cloud.stream.app:throughput-sink-kafka:@throughput-sink.version@
sink.throughput.metadata=maven://org.springframework.cloud.stream.app:throughput-sink-kafka:jar:metadata:@throughput-sink.version@
sink.twitter-message=maven://org.springframework.cloud.stream.app:twitter-message-sink-kafka:@twitter-message-sink.version@
sink.twitter-message.metadata=maven://org.springframework.cloud.stream.app:twitter-message-sink-kafka:jar:metadata:@twitter-message-sink.version@
sink.twitter-update=maven://org.springframework.cloud.stream.app:twitter-update-sink-kafka:@twitter-update-sink.version@
sink.twitter-update.metadata=maven://org.springframework.cloud.stream.app:twitter-update-sink-kafka:jar:metadata:@twitter-update-sink.version@
sink.websocket=maven://org.springframework.cloud.stream.app:websocket-sink-kafka:@websocket-sink.version@
sink.websocket.metadata=maven://org.springframework.cloud.stream.app:websocket-sink-kafka:jar:metadata:@websocket-sink.version@
processor.bridge=maven://org.springframework.cloud.stream.app:bridge-processor-kafka:@bridge-processor.version@
@@ -74,4 +88,6 @@ processor.splitter=maven://org.springframework.cloud.stream.app:splitter-process
processor.splitter.metadata=maven://org.springframework.cloud.stream.app:splitter-processor-kafka:jar:metadata:@splitter-processor.version@
processor.transform=maven://org.springframework.cloud.stream.app:transform-processor-kafka:@transform-processor.version@
processor.transform.metadata=maven://org.springframework.cloud.stream.app:transform-processor-kafka:jar:metadata:@transform-processor.version@
processor.twitter-trend=maven://org.springframework.cloud.stream.app:twitter-trend-processor-kafka:@twitter-trend-processor.version@
processor.twitter-trend.metadata=maven://org.springframework.cloud.stream.app:twitter-trend-processor-kafka:jar:metadata:@twitter-trend-processor.version@

10
applications/stream-applications-build/stream-applications-descriptor/src/main/resources/META-INF/rabbit-apps-docker.properties
View File

@@ -8,8 +8,12 @@ source.load-generator=docker:springcloudstream/load-generator-source-rabbit:@loa
source.mongodb=docker:springcloudstream/mongodb-source-rabbit:@mongodb-source-docker.tag@
source.mqtt=docker:springcloudstream/mqtt-source-rabbit:@mqtt-source-docker.tag@
source.rabbit=docker:springcloudstream/rabbit-source-rabbit:@rabbit-source-docker.tag@
source.s3=docker:springcloudstream/s3-source-rabbit:@s3-source-docker.tag@
source.tcp=docker:springcloudstream/tcp-source-rabbit:@tcp-source-docker.tag@
source.time=docker:springcloudstream/time-source-rabbit:@time-source-docker.tag@
source.twitter-message=docker:springcloudstream/twitter-message-source-rabbit:@twitter-message-source-docker.tag@
source.twitter-search=docker:springcloudstream/twitter-search-source-rabbit:@twitter-search-source-docker.tag@
source.twitter-stream=docker:springcloudstream/twitter-stream-source-rabbit:@twitter-stream-source-docker.tag@
source.websocket=docker:springcloudstream/websocket-source-rabbit:@websocket-source-docker.tag@
sink.cassandra=docker:springcloudstream/cassandra-sink-rabbit:@cassandra-sink-docker.tag@
sink.counter=docker:springcloudstream/counter-sink-rabbit:@counter-sink-docker.tag@
@@ -23,10 +27,13 @@ sink.mqtt=docker:springcloudstream/mqtt-sink-rabbit:@mqtt-sink-docker.tag@
sink.rabbit=docker:springcloudstream/rabbit-sink-rabbit:@rabbit-sink-docker.tag@
sink.redis=docker:springcloudstream/redis-sink-rabbit:@redis-sink-docker.tag@
sink.router=docker:springcloudstream/router-sink-rabbit:@router-sink-docker.tag@
sink.s3=docker:springcloudstream/s3-sink-rabbit:@s3-sink-docker.tag@
sink.sftp=docker:springcloudstream/sftp-sink-rabbit:@sftp-sink-docker.tag@
sink.tcp=docker:springcloudstream/tcp-sink-rabbit:@tcp-sink-docker.tag@
sink.tasklauncher=docker:springcloudstream/tasklauncher-sink-rabbit:@tasklauncher-sink-docker.tag@
sink.tcp=docker:springcloudstream/tcp-sink-rabbit:@tcp-sink-docker.tag@
sink.throughput=docker:springcloudstream/throughput-sink-rabbit:@throughput-sink-docker.tag@
sink.twitter-message=docker:springcloudstream/twitter-message-sink-rabbit:@twitter-message-sink-docker.tag@
sink.twitter-update=docker:springcloudstream/twitter-update-sink-rabbit:@twitter-update-sink-docker.tag@
sink.websocket=docker:springcloudstream/websocket-sink-rabbit:@websocket-sink-docker.tag@
processor.bridge=docker:springcloudstream/bridge-processor-rabbit:@bridge-processor-docker.tag@
processor.filter=docker:springcloudstream/filter-processor-rabbit:@filter-processor-docker.tag@
@@ -36,3 +43,4 @@ processor.http-request=docker:springcloudstream/http-request-processor-rabbit:@h
processor.script=docker:springcloudstream/script-processor-rabbit:@script-processor-docker.tag@
processor.splitter=docker:springcloudstream/splitter-processor-rabbit:@splitter-processor-docker.tag@
processor.transform=docker:springcloudstream/transform-processor-rabbit:@transform-processor-docker.tag@
processor.twitter-trend=docker:springcloudstream/twitter-trend-processor-rabbit:@twitter-trend-processor-docker.tag@

22
applications/stream-applications-build/stream-applications-descriptor/src/main/resources/META-INF/rabbit-apps-maven-repo-url.properties
View File

@@ -18,10 +18,18 @@ source.mqtt=https://@repo-spring-io@/org/springframework/cloud/stream/app/mqtt-s
source.mqtt.metadata=https://@repo-spring-io@/org/springframework/cloud/stream/app/mqtt-source-rabbit/@mqtt-source.version@/mqtt-source-rabbit-@mqtt-source.version@-metadata.jar
source.rabbit=https://@repo-spring-io@/org/springframework/cloud/stream/app/rabbit-source-rabbit/@rabbit-source.version@/rabbit-source-rabbit-@rabbit-source.version@.jar
source.rabbit.metadata=https://@repo-spring-io@/org/springframework/cloud/stream/app/rabbit-source-rabbit/@rabbit-source.version@/rabbit-source-rabbit-@rabbit-source.version@-metadata.jar
source.s3=https://@repo-spring-io@/org/springframework/cloud/stream/app/s3-source-rabbit/@s3-source.version@/s3-source-rabbit-@s3-source.version@.jar
source.s3.metadata=https://@repo-spring-io@/org/springframework/cloud/stream/app/s3-source-rabbit/@s3-source.version@/s3-source-rabbit-@s3-source.version@-metadata.jar
source.tcp=https://@repo-spring-io@/org/springframework/cloud/stream/app/tcp-source-rabbit/@tcp-source.version@/tcp-source-rabbit-@tcp-source.version@.jar
source.tcp.metadata=https://@repo-spring-io@/org/springframework/cloud/stream/app/tcp-source-rabbit/@tcp-source.version@/tcp-source-rabbit-@tcp-source.version@-metadata.jar
source.time=https://@repo-spring-io@/org/springframework/cloud/stream/app/time-source-rabbit/@time-source.version@/time-source-rabbit-@time-source.version@.jar
source.time.metadata=https://@repo-spring-io@/org/springframework/cloud/stream/app/time-source-rabbit/@time-source.version@/time-source-rabbit-@time-source.version@-metadata.jar
source.twitter-message=https://@repo-spring-io@/org/springframework/cloud/stream/app/twitter-message-source-rabbit/@twitter-message-source.version@/twitter-message-source-rabbit-@twitter-message-source.version@.jar
source.twitter-message.metadata=https://@repo-spring-io@/org/springframework/cloud/stream/app/twitter-message-source-rabbit/@twitter-message-source.version@/twitter-message-source-rabbit-@twitter-message-source.version@-metadata.jar
source.twitter-search=https://@repo-spring-io@/org/springframework/cloud/stream/app/twitter-search-source-rabbit/@twitter-search-source.version@/twitter-search-source-rabbit-@twitter-search-source.version@.jar
source.twitter-search.metadata=https://@repo-spring-io@/org/springframework/cloud/stream/app/twitter-search-source-rabbit/@twitter-search-source.version@/twitter-search-source-rabbit-@twitter-search-source.version@-metadata.jar
source.twitter-stream=https://@repo-spring-io@/org/springframework/cloud/stream/app/twitter-stream-source-rabbit/@twitter-stream-source.version@/twitter-stream-source-rabbit-@twitter-stream-source.version@.jar
source.twitter-stream.metadata=https://@repo-spring-io@/org/springframework/cloud/stream/app/twitter-stream-source-rabbit/@twitter-stream-source.version@/twitter-stream-source-rabbit-@twitter-stream-source.version@-metadata.jar
source.websocket=https://@repo-spring-io@/org/springframework/cloud/stream/app/websocket-source-rabbit/@websocket-source.version@/websocket-source-rabbit-@websocket-source.version@.jar
source.websocket.metadata=https://@repo-spring-io@/org/springframework/cloud/stream/app/websocket-source-rabbit/@websocket-source.version@/websocket-source-rabbit-@websocket-source.version@-metadata.jar
sink.cassandra=https://@repo-spring-io@/org/springframework/cloud/stream/app/cassandra-sink-rabbit/@cassandra-sink.version@/cassandra-sink-rabbit-@cassandra-sink.version@.jar
@@ -48,14 +56,20 @@ sink.redis=https://@repo-spring-io@/org/springframework/cloud/stream/app/redis-s
sink.redis.metadata=https://@repo-spring-io@/org/springframework/cloud/stream/app/redis-sink-rabbit/@redis-sink.version@/redis-sink-rabbit-@redis-sink.version@-metadata.jar
sink.router=https://@repo-spring-io@/org/springframework/cloud/stream/app/router-sink-rabbit/@router-sink.version@/router-sink-rabbit-@router-sink.version@.jar
sink.router.metadata=https://@repo-spring-io@/org/springframework/cloud/stream/app/router-sink-rabbit/@router-sink.version@/router-sink-rabbit-@router-sink.version@-metadata.jar
sink.s3=https://@repo-spring-io@/org/springframework/cloud/stream/app/s3-sink-rabbit/@s3-sink.version@/s3-sink-rabbit-@s3-sink.version@.jar
sink.s3.metadata=https://@repo-spring-io@/org/springframework/cloud/stream/app/s3-sink-rabbit/@s3-sink.version@/s3-sink-rabbit-@s3-sink.version@-metadata.jar
sink.sftp=https://@repo-spring-io@/org/springframework/cloud/stream/app/sftp-sink-rabbit/@sftp-sink.version@/sftp-sink-rabbit-@sftp-sink.version@.jar
sink.sftp.metadata=https://@repo-spring-io@/org/springframework/cloud/stream/app/sftp-sink-rabbit/@sftp-sink.version@/sftp-sink-rabbit-@sftp-sink.version@-metadata.jar
sink.tcp=https://@repo-spring-io@/org/springframework/cloud/stream/app/tcp-sink-rabbit/@tcp-sink.version@/tcp-sink-rabbit-@sftp-sink.version@.jar
sink.tcp.metadata=https://@repo-spring-io@/org/springframework/cloud/stream/app/tcp-sink-rabbit/@tcp-sink.version@/tcp-sink-rabbit-@tcp-sink.version@-metadata.jar
sink.tasklauncher=https://@repo-spring-io@/org/springframework/cloud/stream/app/tasklauncher-sink-rabbit/@tasklauncher-sink.version@/tasklauncher-sink-rabbit-@tasklauncher-sink.version@.jar
sink.tasklauncher.metadata=https://@repo-spring-io@/org/springframework/cloud/stream/app/tasklauncher-sink-rabbit/@tasklauncher-sink.version@/tasklauncher-sink-rabbit-@tasklauncher-sink.version@-metadata.jar
sink.tcp=https://@repo-spring-io@/org/springframework/cloud/stream/app/tcp-sink-rabbit/@tcp-sink.version@/tcp-sink-rabbit-@tcp-sink.version@.jar
sink.tcp.metadata=https://@repo-spring-io@/org/springframework/cloud/stream/app/tcp-sink-rabbit/@tcp-sink.version@/tcp-sink-rabbit-@tcp-sink.version@-metadata.jar
sink.throughput=https://@repo-spring-io@/org/springframework/cloud/stream/app/throughput-sink-rabbit/@throughput-sink.version@/throughput-sink-rabbit-@throughput-sink.version@.jar
sink.throughput.metadata=https://@repo-spring-io@/org/springframework/cloud/stream/app/throughput-sink-rabbit/@throughput-sink.version@/throughput-sink-rabbit-@throughput-sink.version@-metadata.jar
sink.twitter-message=https://@repo-spring-io@/org/springframework/cloud/stream/app/twitter-message-sink-rabbit/@twitter-message-sink.version@/twitter-message-sink-rabbit-@twitter-message-sink.version@.jar
sink.twitter-message.metadata=https://@repo-spring-io@/org/springframework/cloud/stream/app/twitter-message-sink-rabbit/@twitter-message-sink.version@/twitter-message-sink-rabbit-@twitter-message-sink.version@-metadata.jar
sink.twitter-update=https://@repo-spring-io@/org/springframework/cloud/stream/app/twitter-update-sink-rabbit/@twitter-update-sink.version@/twitter-update-sink-rabbit-@twitter-update-sink.version@.jar
sink.twitter-update.metadata=https://@repo-spring-io@/org/springframework/cloud/stream/app/twitter-update-sink-rabbit/@twitter-update-sink.version@/twitter-update-sink-rabbit-@twitter-update-sink.version@-metadata.jar
sink.websocket=https://@repo-spring-io@/org/springframework/cloud/stream/app/websocket-sink-rabbit/@websocket-sink.version@/websocket-sink-rabbit-@websocket-sink.version@.jar
sink.websocket.metadata=https://@repo-spring-io@/org/springframework/cloud/stream/app/websocket-sink-rabbit/@websocket-sink.version@/websocket-sink-rabbit-@websocket-sink.version@-metadata.jar
processor.bridge=https://@repo-spring-io@/org/springframework/cloud/stream/app/bridge-processor-rabbit/@bridge-processor.version@/bridge-processor-rabbit-@bridge-processor.version@.jar
@@ -73,4 +87,6 @@ processor.script.metadata=https://@repo-spring-io@/org/springframework/cloud/str
processor.splitter=https://@repo-spring-io@/org/springframework/cloud/stream/app/splitter-processor-rabbit/@splitter-processor.version@/splitter-processor-rabbit-@splitter-processor.version@.jar
processor.splitter.metadata=https://@repo-spring-io@/org/springframework/cloud/stream/app/splitter-processor-rabbit/@splitter-processor.version@/splitter-processor-rabbit-@splitter-processor.version@-metadata.jar
processor.transform=https://@repo-spring-io@/org/springframework/cloud/stream/app/transform-processor-rabbit/@transform-processor.version@/transform-processor-rabbit-@transform-processor.version@.jar
processor.transform.metadata=https://@repo-spring-io@/org/springframework/cloud/stream/app/transform-processor-rabbit/@transform-processor.version@/transform-processor-rabbit-@transform-processor.version@-metadata.jar
processor.transform.metadata=https://@repo-spring-io@/org/springframework/cloud/stream/app/transform-processor-rabbit/@transform-processor.version@/transform-processor-rabbit-@transform-processor.version@-metadata.jar
processor.twitter-trend=https://@repo-spring-io@/org/springframework/cloud/stream/app/twitter-trend-processor-rabbit/@twitter-trend-processor.version@/twitter-trend-processor-rabbit-@twitter-trend-processor.version@.jar
processor.twitter-trend.metadata=https://@repo-spring-io@/org/springframework/cloud/stream/app/twitter-trend-processor-rabbit/@twitter-trend-processor.version@/twitter-trend-processor-rabbit-@twitter-trend-processor.version@-metadata.jar

20
applications/stream-applications-build/stream-applications-descriptor/src/main/resources/META-INF/rabbit-apps-maven.properties
View File

@@ -18,10 +18,18 @@ source.mqtt=maven://org.springframework.cloud.stream.app:mqtt-source-rabbit:@mqt
source.mqtt.metadata=maven://org.springframework.cloud.stream.app:mqtt-source-rabbit:jar:metadata:@mqtt-source.version@
source.rabbit=maven://org.springframework.cloud.stream.app:rabbit-source-rabbit:@rabbit-source.version@
source.rabbit.metadata=maven://org.springframework.cloud.stream.app:rabbit-source-rabbit:jar:metadata:@rabbit-source.version@
source.s3=maven://org.springframework.cloud.stream.app:s3-source-rabbit:@s3-source.version@
source.s3.metadata=maven://org.springframework.cloud.stream.app:s3-source-rabbit:jar:metadata:@s3-source.version@
source.tcp=maven://org.springframework.cloud.stream.app:tcp-source-rabbit:@tcp-source.version@
source.tcp.metadata=maven://org.springframework.cloud.stream.app:tcp-source-rabbit:jar:metadata:@tcp-source.version@
source.time=maven://org.springframework.cloud.stream.app:time-source-rabbit:@time-source.version@
source.time.metadata=maven://org.springframework.cloud.stream.app:time-source-rabbit:jar:metadata:@time-source.version@
source.twitter-message=maven://org.springframework.cloud.stream.app:twitter-message-source-rabbit:@twitter-message-source.version@
source.twitter-message.metadata=maven://org.springframework.cloud.stream.app:twitter-message-source-rabbit:jar:metadata:@twitter-message-source.version@
source.twitter-search=maven://org.springframework.cloud.stream.app:twitter-search-source-rabbit:@twitter-search-source.version@
source.twitter-search.metadata=maven://org.springframework.cloud.stream.app:twitter-search-source-rabbit:jar:metadata:@twitter-search-source.version@
source.twitter-stream=maven://org.springframework.cloud.stream.app:twitter-stream-source-rabbit:@twitter-stream-source.version@
source.twitter-stream.metadata=maven://org.springframework.cloud.stream.app:twitter-stream-source-rabbit:jar:metadata:@twitter-stream-source.version@
source.websocket=maven://org.springframework.cloud.stream.app:websocket-source-rabbit:@websocket-source.version@
source.websocket.metadata=maven://org.springframework.cloud.stream.app:websocket-source-rabbit:jar:metadata:@websocket-source.version@
sink.cassandra=maven://org.springframework.cloud.stream.app:cassandra-sink-rabbit:@cassandra-sink.version@
@@ -48,14 +56,20 @@ sink.redis=maven://org.springframework.cloud.stream.app:redis-sink-rabbit:@redis
sink.redis.metadata=maven://org.springframework.cloud.stream.app:redis-sink-rabbit:jar:metadata:@redis-sink.version@
sink.router=maven://org.springframework.cloud.stream.app:router-sink-rabbit:@router-sink.version@
sink.router.metadata=maven://org.springframework.cloud.stream.app:router-sink-rabbit:jar:metadata:@router-sink.version@
sink.s3=maven://org.springframework.cloud.stream.app:s3-sink-rabbit:@s3-sink.version@
sink.s3.metadata=maven://org.springframework.cloud.stream.app:s3-sink-rabbit:jar:metadata:@s3-sink.version@
sink.sftp=maven://org.springframework.cloud.stream.app:sftp-sink-rabbit:@sftp-sink.version@
sink.sftp.metadata=maven://org.springframework.cloud.stream.app:sftp-sink-rabbit:jar:metadata:@sftp-sink.version@
sink.tcp=maven://org.springframework.cloud.stream.app:tcp-sink-rabbit:@tcp-sink.version@
sink.tcp.metadata=maven://org.springframework.cloud.stream.app:tcp-sink-rabbit:jar:metadata:@tcp-sink.version@
sink.tasklauncher=maven://org.springframework.cloud.stream.app:tasklauncher-sink-rabbit:@tasklauncher-sink.version@
sink.tasklauncher.metadata=maven://org.springframework.cloud.stream.app:tasklauncher-sink-rabbit:jar:metadata:@tasklauncher-sink.version@
sink.tcp=maven://org.springframework.cloud.stream.app:tcp-sink-rabbit:@tcp-sink.version@
sink.tcp.metadata=maven://org.springframework.cloud.stream.app:tcp-sink-rabbit:jar:metadata:@tcp-sink.version@
sink.throughput=maven://org.springframework.cloud.stream.app:throughput-sink-rabbit:@throughput-sink.version@
sink.throughput.metadata=maven://org.springframework.cloud.stream.app:throughput-sink-rabbit:jar:metadata:@throughput-sink.version@
sink.twitter-message=maven://org.springframework.cloud.stream.app:twitter-message-sink-rabbit:@twitter-message-sink.version@
sink.twitter-message.metadata=maven://org.springframework.cloud.stream.app:twitter-message-sink-rabbit:jar:metadata:@twitter-message-sink.version@
sink.twitter-update=maven://org.springframework.cloud.stream.app:twitter-update-sink-rabbit:@twitter-update-sink.version@
sink.twitter-update.metadata=maven://org.springframework.cloud.stream.app:twitter-update-sink-rabbit:jar:metadata:@twitter-update-sink.version@
sink.websocket=maven://org.springframework.cloud.stream.app:websocket-sink-rabbit:@websocket-sink.version@
sink.websocket.metadata=maven://org.springframework.cloud.stream.app:websocket-sink-rabbit:jar:metadata:@websocket-sink.version@
processor.bridge=maven://org.springframework.cloud.stream.app:bridge-processor-rabbit:@bridge-processor.version@
@@ -74,4 +88,6 @@ processor.splitter=maven://org.springframework.cloud.stream.app:splitter-process
processor.splitter.metadata=maven://org.springframework.cloud.stream.app:splitter-processor-rabbit:jar:metadata:@splitter-processor.version@
processor.transform=maven://org.springframework.cloud.stream.app:transform-processor-rabbit:@transform-processor.version@
processor.transform.metadata=maven://org.springframework.cloud.stream.app:transform-processor-rabbit:jar:metadata:@transform-processor.version@
processor.twitter-trend=maven://org.springframework.cloud.stream.app:twitter-trend-processor-rabbit:@twitter-trend-processor.version@
processor.twitter-trend.metadata=maven://org.springframework.cloud.stream.app:twitter-trend-processor-rabbit:jar:metadata:@twitter-trend-processor.version@

41
applications/stream-applications-build/stream-applications-docs/pom.xml
View File

@@ -56,6 +56,11 @@
<artifactId>tcp-common</artifactId>
<version>${java-functions.version}</version>
</dependency>
<dependency>
<groupId>org.springframework.cloud.fn</groupId>
<artifactId>twitter-common</artifactId>
<version>${java-functions.version}</version>
</dependency>
<!-- supplier javadocs -->
<dependency>
<groupId>org.springframework.cloud.fn</groupId>
@@ -102,6 +107,11 @@
<artifactId>rabbit-supplier</artifactId>
<version>${java-functions.version}</version>
</dependency>
<dependency>
<groupId>org.springframework.cloud.fn</groupId>
<artifactId>s3-supplier</artifactId>
<version>${java-functions.version}</version>
</dependency>
<dependency>
<groupId>org.springframework.cloud.fn</groupId>
<artifactId>tcp-supplier</artifactId>
@@ -112,6 +122,11 @@
<artifactId>time-supplier</artifactId>
<version>${java-functions.version}</version>
</dependency>
<dependency>
<groupId>org.springframework.cloud.fn</groupId>
<artifactId>twitter-supplier</artifactId>
<version>${java-functions.version}</version>
</dependency>
<dependency>
<groupId>org.springframework.cloud.fn</groupId>
<artifactId>websocket-supplier</artifactId>
@@ -174,9 +189,9 @@
<version>${java-functions.version}</version>
</dependency>
<dependency>
<groupId>org.springframework.cloud.stream.app</groupId>
<artifactId>router-sink</artifactId>
<version>${router-sink.version}</version>
<groupId>org.springframework.cloud.fn</groupId>
<artifactId>s3-consumer</artifactId>
<version>${java-functions.version}</version>
</dependency>
<dependency>
<groupId>org.springframework.cloud.fn</groupId>
@@ -188,6 +203,11 @@
<artifactId>tcp-consumer</artifactId>
<version>${java-functions.version}</version>
</dependency>
<dependency>
<groupId>org.springframework.cloud.fn</groupId>
<artifactId>twitter-consumer</artifactId>
<version>${java-functions.version}</version>
</dependency>
<dependency>
<groupId>org.springframework.cloud.fn</groupId>
<artifactId>websocket-consumer</artifactId>
@@ -214,17 +234,32 @@
<artifactId>splitter-function</artifactId>
<version>${java-functions.version}</version>
</dependency>
<dependency>
<groupId>org.springframework.cloud.fn</groupId>
<artifactId>task-launch-request-function</artifactId>
<version>${java-functions.version}</version>
</dependency>
<dependency>
<groupId>org.springframework.cloud.fn</groupId>
<artifactId>tasklauncher-function</artifactId>
<version>${java-functions.version}</version>
</dependency>
<dependency>
<groupId>org.springframework.cloud.fn</groupId>
<artifactId>twitter-function</artifactId>
<version>${java-functions.version}</version>
</dependency>
<!-- Apps don't use external functions as baseline, but contain @ConfigurationProperties -->
<dependency>
<groupId>org.springframework.cloud.stream.app</groupId>
<artifactId>load-generator-source</artifactId>
<version>${load-generator-source.version}</version>
</dependency>
<dependency>
<groupId>org.springframework.cloud.stream.app</groupId>
<artifactId>router-sink</artifactId>
<version>${router-sink.version}</version>
</dependency>
<dependency>
<groupId>org.springframework.cloud.stream.app</groupId>
<artifactId>throughput-sink</artifactId>

3
applications/stream-applications-build/stream-applications-docs/src/main/asciidoc/processors.adoc
View File

@@ -27,6 +27,9 @@ include::{stream-apps-root}/{branch}/applications/processor/splitter-processor/R
[[spring-cloud-stream-modules-transform-processor]]
include::{stream-apps-root}/{branch}/applications/processor/transform-processor/README.adoc[tags=ref-doc]
[[spring-cloud-stream-modules-transform-processor]]
include::{stream-apps-root}/{branch}/applications/processor/transform-processor/README.adoc[tags=ref-doc]
:leveloffset: -2

15
applications/stream-applications-build/stream-applications-docs/src/main/asciidoc/sinks.adoc
View File

@@ -39,18 +39,27 @@ include::{stream-apps-root}/{branch}/applications/sink/redis-sink/README.adoc[ta
[[spring-cloud-stream-modules-router-sink]]
include::{stream-apps-root}/{branch}/applications/sink/router-sink/README.adoc[tags=ref-doc]
[[spring-cloud-stream-modules-s3-sink]]
include::{stream-apps-root}/{branch}/applications/sink/s3-sink/README.adoc[tags=ref-doc]
[[spring-cloud-stream-modules-sftp-sink]]
include::{stream-apps-root}/{branch}/applications/sink/tasklauncher-sink/README.adoc[tags=ref-doc]
[[spring-cloud-stream-modules-tasklauncher-sink]]
include::{stream-apps-root}/{branch}/applications/sink/sftp-sink/README.adoc[tags=ref-doc]
[[spring-cloud-stream-modules-tcp-sink]]
include::{stream-apps-root}/{branch}/applications/sink/tcp-sink/README.adoc[tags=ref-doc]
[[spring-cloud-stream-modules-tasklauncher-sink]]
include::{stream-apps-root}/{branch}/applications/sink/tasklauncher-sink/README.adoc[tags=ref-doc]
[[spring-cloud-stream-modules-throughput-sink]]
include::{stream-apps-root}/{branch}/applications/sink/throughput-sink/README.adoc[tags=ref-doc]
[[spring-cloud-stream-modules-twitter-message-sink]]
include::{stream-apps-root}/{branch}/applications/sink/twitter-message-sink/README.adoc[tags=ref-doc]
[[spring-cloud-stream-modules-twitter-update-sink]]
include::{stream-apps-root}/{branch}/applications/sink/twitter-update-sink/README.adoc[tags=ref-doc]
[[spring-cloud-stream-modules-websocket-sink]]
include::{stream-apps-root}/{branch}/applications/sink/websocket-sink/README.adoc[tags=ref-doc]

12
applications/stream-applications-build/stream-applications-docs/src/main/asciidoc/sources.adoc
View File

@@ -33,12 +33,24 @@ include::{stream-apps-root}/{branch}/applications/source/mqtt-source/README.adoc
[[spring-cloud-stream-modules-rabbit-source]]
include::{stream-apps-root}/{branch}/applications/source/rabbit-source/README.adoc[tags=ref-doc]
[[spring-cloud-stream-modules-s3-source]]
include::{stream-apps-root}/{branch}/applications/source/s3-source/README.adoc[tags=ref-doc]
[[spring-cloud-stream-modules-tcp-source]]
include::{stream-apps-root}/{branch}/applications/source/tcp-source/README.adoc[tags=ref-doc]
[[spring-cloud-stream-modules-time-source]]
include::{stream-apps-root}/{branch}/applications/source/time-source/README.adoc[tags=ref-doc]
[[spring-cloud-stream-modules-twitter-message-source]]
include::{stream-apps-root}/{branch}/applications/source/twitter-message-source/README.adoc[tags=ref-doc]
[[spring-cloud-stream-modules-twitter-search-source]]
include::{stream-apps-root}/{branch}/applications/source/twitter-search-source/README.adoc[tags=ref-doc]
[[spring-cloud-stream-modules-twitter-stream-source]]
include::{stream-apps-root}/{branch}/applications/source/twitter-stream-source/README.adoc[tags=ref-doc]
[[spring-cloud-stream-modules-websocket-source]]
include::{stream-apps-root}/{branch}/applications/source/websocket-source/README.adoc[tags=ref-doc]

2
applications/stream-applications-core/common/stream-applications-security-common/README.adoc
View File

@@ -22,7 +22,7 @@ To include app starters security management for a stream app, just include a dep
----
<dependency>
<groupId>org.springframework.cloud.stream.app</groupId>
<artifactId>app-starters-security-common</artifactId>
<artifactId>stream-applications-security-common</artifactId>
</dependency>
----

18
applications/stream-applications-core/pom.xml
View File

@@ -17,17 +17,17 @@
<properties>
<java.version>1.8</java.version>
<stream-apps-core.version>3.0.0-SNAPSHOT</stream-apps-core.version>
<spring-boot.version>2.3.0.RELEASE</spring-boot.version>
<app-metadata-maven-plugin-version>2.0.1.M1</app-metadata-maven-plugin-version>
<spring-boot.version>2.3.1.RELEASE</spring-boot.version>
<stream-apps-core.version>${project.version}</stream-apps-core.version>
<java-functions.version>1.0.0-SNAPSHOT</java-functions.version>
<scst-app-maven-plugin.version>2.0.0.M2</scst-app-maven-plugin.version>
<app-metadata-maven-plugin-version>2.0.1.M1</app-metadata-maven-plugin-version>
<stream-apps-docs-plugin.version>3.0.0.M1</stream-apps-docs-plugin.version>
<spring-cloud-stream.version>3.0.2.RELEASE</spring-cloud-stream.version>
<spring-cloud-function-dependencies.version>3.0.8.RELEASE</spring-cloud-function-dependencies.version>
<spring-cloud-dependencies.version>Hoxton.BUILD-SNAPSHOT</spring-cloud-dependencies.version>
<spring-cloud-dependencies.version>Hoxton.SR6</spring-cloud-dependencies.version>
<spring-cloud-stream-dependencies.version>Horsham.SR6</spring-cloud-stream-dependencies.version>
<java-cfenv-boot.version>2.1.2.RELEASE</java-cfenv-boot.version>
<java-functions.version>1.0.0-SNAPSHOT</java-functions.version>
<prometheus-rsocket.version>0.9.0</prometheus-rsocket.version>
<maven-source-plugin.version>3.0.1</maven-source-plugin.version>
<maven-checkstyle-plugin.version>3.1.0</maven-checkstyle-plugin.version>
@@ -47,8 +47,6 @@
<nohttp-checkstyle.version>0.0.2.RELEASE</nohttp-checkstyle.version>
<disable.nohttp.checks>true</disable.nohttp.checks>
<spring-javaformat-checkstyle.version>0.0.7</spring-javaformat-checkstyle.version>
<spring-cloud-build.version>3.0.0-SNAPSHOT</spring-cloud-build.version>
<maven-javadoc-plugin.version>3.1.1</maven-javadoc-plugin.version>
<mockserver.version>5.10</mockserver.version>
</properties>
@@ -320,7 +318,6 @@
</plugins>
</pluginManagement>
<plugins>
<plugin>
<artifactId>maven-javadoc-plugin</artifactId>
@@ -380,11 +377,6 @@
<artifactId>spring-javaformat-checkstyle</artifactId>
<version>${spring-javaformat-checkstyle.version}</version>
</dependency>
<dependency>
<groupId>org.springframework.cloud</groupId>
<artifactId>spring-cloud-build-tools</artifactId>
<version>${spring-cloud-build.version}</version>
</dependency>
<dependency>
<groupId>io.spring.nohttp</groupId>
<artifactId>nohttp-checkstyle</artifactId>

2
functions/consumer/cassandra-consumer/pom.xml
View File

@@ -15,7 +15,7 @@
</parent>
<properties>
<springIntegrationCassandara.version>0.8.0.BUILD-SNAPSHOT</springIntegrationCassandara.version>
<springIntegrationCassandara.version>0.8.0.RELEASE</springIntegrationCassandara.version>
<cassandra-unit-spring.version>4.3.1.0</cassandra-unit-spring.version>
</properties>

2
functions/spring-functions-parent/pom.xml
View File

@@ -15,7 +15,7 @@
<packaging>pom</packaging>
<properties>
<spring-boot.version>2.3.0.RELEASE</spring-boot.version>
<spring-boot.version>2.3.1.RELEASE</spring-boot.version>
<spring-cloud-function.version>3.0.8.RELEASE</spring-cloud-function.version>
<spring-cloud-fn.version>${project.version}</spring-cloud-fn.version>
</properties>