diff --git a/README.adoc b/README.adoc index 53eace02..314899a4 100644 --- a/README.adoc +++ b/README.adoc @@ -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] | |=== diff --git a/applications/stream-applications-build/pom.xml b/applications/stream-applications-build/pom.xml index 41ea2044..880896e4 100644 --- a/applications/stream-applications-build/pom.xml +++ b/applications/stream-applications-build/pom.xml @@ -29,8 +29,12 @@ 3.0.0-SNAPSHOT 3.0.0-SNAPSHOT 3.0.0-SNAPSHOT + 3.0.0-SNAPSHOT 3.0.0-SNAPSHOT 3.0.0-SNAPSHOT + 3.0.0-SNAPSHOT + 3.0.0-SNAPSHOT + 3.0.0-SNAPSHOT 3.0.0-SNAPSHOT 3.0.0-SNAPSHOT 3.0.0-SNAPSHOT @@ -44,10 +48,13 @@ 3.0.0-SNAPSHOT 3.0.0-SNAPSHOT 3.0.0-SNAPSHOT + 3.0.0-SNAPSHOT 3.0.0-SNAPSHOT - 3.0.0-SNAPSHOT 3.0.0-SNAPSHOT + 3.0.0-SNAPSHOT 3.0.0-SNAPSHOT + 3.0.0-SNAPSHOT + 3.0.0-SNAPSHOT 3.0.0-SNAPSHOT 3.0.0-SNAPSHOT 3.0.0-SNAPSHOT @@ -57,6 +64,7 @@ 3.0.0-SNAPSHOT 3.0.0-SNAPSHOT 3.0.0-SNAPSHOT + 3.0.0-SNAPSHOT diff --git a/applications/stream-applications-build/stream-applications-descriptor/pom.xml b/applications/stream-applications-build/stream-applications-descriptor/pom.xml index d4605e88..12211d10 100644 --- a/applications/stream-applications-build/stream-applications-descriptor/pom.xml +++ b/applications/stream-applications-build/stream-applications-descriptor/pom.xml @@ -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}" ]]> diff --git a/applications/stream-applications-build/stream-applications-descriptor/src/main/resources/META-INF/kafka-apps-docker.properties b/applications/stream-applications-build/stream-applications-descriptor/src/main/resources/META-INF/kafka-apps-docker.properties index dee68056..d1f82a74 100644 --- a/applications/stream-applications-build/stream-applications-descriptor/src/main/resources/META-INF/kafka-apps-docker.properties +++ b/applications/stream-applications-build/stream-applications-descriptor/src/main/resources/META-INF/kafka-apps-docker.properties @@ -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@ diff --git a/applications/stream-applications-build/stream-applications-descriptor/src/main/resources/META-INF/kafka-apps-maven-repo-url.properties b/applications/stream-applications-build/stream-applications-descriptor/src/main/resources/META-INF/kafka-apps-maven-repo-url.properties index 977765f1..d9a46ce0 100644 --- a/applications/stream-applications-build/stream-applications-descriptor/src/main/resources/META-INF/kafka-apps-maven-repo-url.properties +++ b/applications/stream-applications-build/stream-applications-descriptor/src/main/resources/META-INF/kafka-apps-maven-repo-url.properties @@ -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 \ No newline at end of file +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 \ No newline at end of file diff --git a/applications/stream-applications-build/stream-applications-descriptor/src/main/resources/META-INF/kafka-apps-maven.properties b/applications/stream-applications-build/stream-applications-descriptor/src/main/resources/META-INF/kafka-apps-maven.properties index 6c7a564c..105c02ad 100644 --- a/applications/stream-applications-build/stream-applications-descriptor/src/main/resources/META-INF/kafka-apps-maven.properties +++ b/applications/stream-applications-build/stream-applications-descriptor/src/main/resources/META-INF/kafka-apps-maven.properties @@ -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@ diff --git a/applications/stream-applications-build/stream-applications-descriptor/src/main/resources/META-INF/rabbit-apps-docker.properties b/applications/stream-applications-build/stream-applications-descriptor/src/main/resources/META-INF/rabbit-apps-docker.properties index bdf01802..118e08a3 100644 --- a/applications/stream-applications-build/stream-applications-descriptor/src/main/resources/META-INF/rabbit-apps-docker.properties +++ b/applications/stream-applications-build/stream-applications-descriptor/src/main/resources/META-INF/rabbit-apps-docker.properties @@ -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@ diff --git a/applications/stream-applications-build/stream-applications-descriptor/src/main/resources/META-INF/rabbit-apps-maven-repo-url.properties b/applications/stream-applications-build/stream-applications-descriptor/src/main/resources/META-INF/rabbit-apps-maven-repo-url.properties index a40c0ef7..6d4b0e36 100644 --- a/applications/stream-applications-build/stream-applications-descriptor/src/main/resources/META-INF/rabbit-apps-maven-repo-url.properties +++ b/applications/stream-applications-build/stream-applications-descriptor/src/main/resources/META-INF/rabbit-apps-maven-repo-url.properties @@ -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 \ No newline at end of file +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 \ No newline at end of file diff --git a/applications/stream-applications-build/stream-applications-descriptor/src/main/resources/META-INF/rabbit-apps-maven.properties b/applications/stream-applications-build/stream-applications-descriptor/src/main/resources/META-INF/rabbit-apps-maven.properties index 58106822..d0518d22 100644 --- a/applications/stream-applications-build/stream-applications-descriptor/src/main/resources/META-INF/rabbit-apps-maven.properties +++ b/applications/stream-applications-build/stream-applications-descriptor/src/main/resources/META-INF/rabbit-apps-maven.properties @@ -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@ diff --git a/applications/stream-applications-build/stream-applications-docs/pom.xml b/applications/stream-applications-build/stream-applications-docs/pom.xml index 45e2473a..d3518de8 100644 --- a/applications/stream-applications-build/stream-applications-docs/pom.xml +++ b/applications/stream-applications-build/stream-applications-docs/pom.xml @@ -56,6 +56,11 @@ tcp-common ${java-functions.version} + + org.springframework.cloud.fn + twitter-common + ${java-functions.version} + org.springframework.cloud.fn @@ -102,6 +107,11 @@ rabbit-supplier ${java-functions.version} + + org.springframework.cloud.fn + s3-supplier + ${java-functions.version} + org.springframework.cloud.fn tcp-supplier @@ -112,6 +122,11 @@ time-supplier ${java-functions.version} + + org.springframework.cloud.fn + twitter-supplier + ${java-functions.version} + org.springframework.cloud.fn websocket-supplier @@ -174,9 +189,9 @@ ${java-functions.version} - org.springframework.cloud.stream.app - router-sink - ${router-sink.version} + org.springframework.cloud.fn + s3-consumer + ${java-functions.version} org.springframework.cloud.fn @@ -188,6 +203,11 @@ tcp-consumer ${java-functions.version} + + org.springframework.cloud.fn + twitter-consumer + ${java-functions.version} + org.springframework.cloud.fn websocket-consumer @@ -214,17 +234,32 @@ splitter-function ${java-functions.version} + + org.springframework.cloud.fn + task-launch-request-function + ${java-functions.version} + org.springframework.cloud.fn tasklauncher-function ${java-functions.version} + + org.springframework.cloud.fn + twitter-function + ${java-functions.version} + org.springframework.cloud.stream.app load-generator-source ${load-generator-source.version} + + org.springframework.cloud.stream.app + router-sink + ${router-sink.version} + org.springframework.cloud.stream.app throughput-sink diff --git a/applications/stream-applications-build/stream-applications-docs/src/main/asciidoc/processors.adoc b/applications/stream-applications-build/stream-applications-docs/src/main/asciidoc/processors.adoc index 37ab8d1e..f64e670c 100644 --- a/applications/stream-applications-build/stream-applications-docs/src/main/asciidoc/processors.adoc +++ b/applications/stream-applications-build/stream-applications-docs/src/main/asciidoc/processors.adoc @@ -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 diff --git a/applications/stream-applications-build/stream-applications-docs/src/main/asciidoc/sinks.adoc b/applications/stream-applications-build/stream-applications-docs/src/main/asciidoc/sinks.adoc index 6a91a8b8..f18b2def 100644 --- a/applications/stream-applications-build/stream-applications-docs/src/main/asciidoc/sinks.adoc +++ b/applications/stream-applications-build/stream-applications-docs/src/main/asciidoc/sinks.adoc @@ -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] diff --git a/applications/stream-applications-build/stream-applications-docs/src/main/asciidoc/sources.adoc b/applications/stream-applications-build/stream-applications-docs/src/main/asciidoc/sources.adoc index 4c99633e..288f2729 100644 --- a/applications/stream-applications-build/stream-applications-docs/src/main/asciidoc/sources.adoc +++ b/applications/stream-applications-build/stream-applications-docs/src/main/asciidoc/sources.adoc @@ -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] diff --git a/applications/stream-applications-core/common/stream-applications-security-common/README.adoc b/applications/stream-applications-core/common/stream-applications-security-common/README.adoc index b58001d6..d87c31cf 100644 --- a/applications/stream-applications-core/common/stream-applications-security-common/README.adoc +++ b/applications/stream-applications-core/common/stream-applications-security-common/README.adoc @@ -22,7 +22,7 @@ To include app starters security management for a stream app, just include a dep ---- org.springframework.cloud.stream.app - app-starters-security-common + stream-applications-security-common ---- diff --git a/applications/stream-applications-core/pom.xml b/applications/stream-applications-core/pom.xml index 5167ab13..6ccd05c8 100644 --- a/applications/stream-applications-core/pom.xml +++ b/applications/stream-applications-core/pom.xml @@ -17,17 +17,17 @@ 1.8 - 3.0.0-SNAPSHOT - 2.3.0.RELEASE - 2.0.1.M1 + 2.3.1.RELEASE + ${project.version} + 1.0.0-SNAPSHOT 2.0.0.M2 + 2.0.1.M1 3.0.0.M1 3.0.2.RELEASE 3.0.8.RELEASE - Hoxton.BUILD-SNAPSHOT + Hoxton.SR6 Horsham.SR6 2.1.2.RELEASE - 1.0.0-SNAPSHOT 0.9.0 3.0.1 3.1.0 @@ -47,8 +47,6 @@ 0.0.2.RELEASE true 0.0.7 - 3.0.0-SNAPSHOT - 3.1.1 5.10 @@ -320,7 +318,6 @@ - maven-javadoc-plugin @@ -380,11 +377,6 @@ spring-javaformat-checkstyle ${spring-javaformat-checkstyle.version} - - org.springframework.cloud - spring-cloud-build-tools - ${spring-cloud-build.version} - io.spring.nohttp nohttp-checkstyle diff --git a/functions/consumer/cassandra-consumer/pom.xml b/functions/consumer/cassandra-consumer/pom.xml index f60aab2d..60a847dd 100644 --- a/functions/consumer/cassandra-consumer/pom.xml +++ b/functions/consumer/cassandra-consumer/pom.xml @@ -15,7 +15,7 @@ - 0.8.0.BUILD-SNAPSHOT + 0.8.0.RELEASE 4.3.1.0 diff --git a/functions/spring-functions-parent/pom.xml b/functions/spring-functions-parent/pom.xml index a26b2e22..60e53af4 100644 --- a/functions/spring-functions-parent/pom.xml +++ b/functions/spring-functions-parent/pom.xml @@ -15,7 +15,7 @@ pom - 2.3.0.RELEASE + 2.3.1.RELEASE 3.0.8.RELEASE ${project.version}