diff --git a/applications/stream-applications-build/pom.xml b/applications/stream-applications-build/pom.xml
index 3994f094..051b3ee0 100644
--- a/applications/stream-applications-build/pom.xml
+++ b/applications/stream-applications-build/pom.xml
@@ -28,10 +28,12 @@
         <jdbc-source.version>${apps.version}</jdbc-source.version>
         <jms-source.version>${apps.version}</jms-source.version>
         <load-generator-source.version>${apps.version}</load-generator-source.version>
+        <mail-source.version>${apps.version}</mail-source.version>
         <mongodb-source.version>${apps.version}</mongodb-source.version>
         <mqtt-source.version>${apps.version}</mqtt-source.version>
         <rabbit-source.version>${apps.version}</rabbit-source.version>
         <s3-source.version>${apps.version}</s3-source.version>
+        <syslog-source.version>${apps.version}</syslog-source.version>
         <sftp-source.version>${apps.version}</sftp-source.version>
         <tcp-source.version>${apps.version}</tcp-source.version>
         <time-source.version>${apps.version}</time-source.version>
@@ -51,6 +53,8 @@
         <rabbit-sink.version>${apps.version}</rabbit-sink.version>
         <redis-sink.version>${apps.version}</redis-sink.version>
         <router-sink.version>${apps.version}</router-sink.version>
+        <rsocket-sink.version>${apps.version}</rsocket-sink.version>
+        <pgcopy-sink.version>${apps.version}</pgcopy-sink.version>
         <s3-sink.version>${apps.version}</s3-sink.version>
         <sftp-sink.version>${apps.version}</sftp-sink.version>
         <tasklauncher-sink.version>${apps.version}</tasklauncher-sink.version>
@@ -60,6 +64,7 @@
         <twitter-update-sink.version>${apps.version}</twitter-update-sink.version>
         <wavefront-sink.version>${apps.version}</wavefront-sink.version>
         <websocket-sink.version>${apps.version}</websocket-sink.version>
+        <aggregator-processor.version>${apps.version}</aggregator-processor.version>
         <bridge-processor.version>${apps.version}</bridge-processor.version>
         <filter-processor.version>${apps.version}</filter-processor.version>
         <groovy-processor.version>${apps.version}</groovy-processor.version>
diff --git a/applications/stream-applications-build/stream-applications-descriptor/pom.xml b/applications/stream-applications-build/stream-applications-descriptor/pom.xml
index e80d1102..9ce45e8e 100644
--- a/applications/stream-applications-build/stream-applications-descriptor/pom.xml
+++ b/applications/stream-applications-build/stream-applications-descriptor/pom.xml
@@ -59,6 +59,8 @@
                 "${jms-source.version}".contains('SNAPSHOT') ? 'latest' : "${jms-source.version}"
         pom.properties['load-generator-source-docker.tag']=
                 "${load-generator-source.version}".contains('SNAPSHOT') ? 'latest' : "${load-generator-source.version}"
+        pom.properties['mail-source-docker.tag']=
+                "${mail-source.version}".contains('SNAPSHOT') ? 'latest' : "${mail-source.version}"
         pom.properties['mongodb-source-docker.tag']=
                 "${mongodb-source.version}".contains('SNAPSHOT') ? 'latest' : "${mongodb-source.version}"
         pom.properties['mqtt-source-docker.tag']=
@@ -69,6 +71,8 @@
                 "${s3-source.version}".contains('SNAPSHOT') ? 'latest' : "${s3-source.version}"
         pom.properties['sftp-source-docker.tag']=
                 "${sftp-source.version}".contains('SNAPSHOT') ? 'latest' : "${sftp-source.version}"
+        pom.properties['syslog-source-docker.tag']=
+                "${syslog-source.version}".contains('SNAPSHOT') ? 'latest' : "${syslog-source.version}"
         pom.properties['tcp-source-docker.tag']=
                 "${tcp-source.version}".contains('SNAPSHOT') ? 'latest' : "${tcp-source.version}"
         pom.properties['time-source-docker.tag']=
@@ -101,12 +105,16 @@
                 "${mongodb-sink.version}".contains('SNAPSHOT') ? 'latest' : "${mongodb-sink.version}"
         pom.properties['mqtt-sink-docker.tag']=
                 "${mqtt-sink.version}".contains('SNAPSHOT') ? 'latest' : "${mqtt-sink.version}"
+        pom.properties['pgcopy-sink-docker.tag']=
+                "${pgcopy-sink.version}".contains('SNAPSHOT') ? 'latest' : "${pgcopy-sink.version}"
         pom.properties['rabbit-sink-docker.tag']=
                 "${rabbit-sink.version}".contains('SNAPSHOT') ? 'latest' : "${rabbit-sink.version}"
         pom.properties['redis-sink-docker.tag']=
                 "${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['rsocket-sink-docker.tag']=
+                "${rsocket-sink.version}".contains('SNAPSHOT') ? 'latest' : "${rsocket-sink.version}"
         pom.properties['s3-sink-docker.tag']=
                 "${s3-sink.version}".contains('SNAPSHOT') ? 'latest' : "${s3-sink.version}"
         pom.properties['sftp-sink-docker.tag']=
@@ -123,6 +131,8 @@
                 "${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['aggregator-processor-docker.tag']=
+                "${aggregator-processor.version}".contains('SNAPSHOT') ? 'latest' : "${aggregator-processor.version}"
         pom.properties['bridge-processor-docker.tag']=
                 "${bridge-processor.version}".contains('SNAPSHOT') ? 'latest' : "${bridge-processor.version}"
         pom.properties['filter-processor-docker.tag']=
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 35700caf..1cd78290 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
@@ -6,11 +6,13 @@ source.http=docker:springcloudstream/http-source-kafka:@http-source-docker.tag@
 source.jdbc=docker:springcloudstream/jdbc-source-kafka:@jdbc-source-docker.tag@
 source.jms=docker:springcloudstream/jms-source-kafka:@jms-source-docker.tag@
 source.load-generator=docker:springcloudstream/load-generator-source-kafka:@load-generator-source-docker.tag@
+source.mail=docker:springcloudstream/mail-source-kafka:@mail-source-docker.tag@
 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.sftp=docker:springcloudstream/sftp-source-kafka:@sftp-source-docker.tag@
+source.syslog=docker:springcloudstream/syslog-source-kafka:@syslog-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@
@@ -27,9 +29,11 @@ sink.jdbc=docker:springcloudstream/jdbc-sink-kafka:@jdbc-sink-docker.tag@
 sink.log=docker:springcloudstream/log-sink-kafka:@log-sink-docker.tag@
 sink.mongodb=docker:springcloudstream/mongodb-sink-kafka:@mongodb-sink-docker.tag@
 sink.mqtt=docker:springcloudstream/mqtt-sink-kafka:@mqtt-sink-docker.tag@
+sink.pgcopy=docker:springcloudstream/pgcopy-sink-kafka:@pgcopy-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.rsocket=docker:springcloudstream/rsocket-sink-kafka:@rsocket-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.tasklauncher=docker:springcloudstream/tasklauncher-sink-kafka:@tasklauncher-sink-docker.tag@
@@ -38,6 +42,7 @@ sink.throughput=docker:springcloudstream/throughput-sink-kafka:@throughput-sink-
 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.aggregator=docker:springcloudstream/aggregator-processor-kafka:@aggregator-processor-docker.tag@
 processor.bridge=docker:springcloudstream/bridge-processor-kafka:@bridge-processor-docker.tag@
 processor.filter=docker:springcloudstream/filter-processor-kafka:@filter-processor-docker.tag@
 processor.groovy=docker:springcloudstream/groovy-processor-kafka:@groovy-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 50de05ca..7f754642 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
@@ -14,6 +14,8 @@ source.jms=https://@repo-spring-io@/org/springframework/cloud/stream/app/jms-sou
 source.jms.metadata=https://@repo-spring-io@/org/springframework/cloud/stream/app/jms-source-kafka/@jms-source.version@/jms-source-kafka-@jms-source.version@-metadata.jar
 source.load-generator=https://@repo-spring-io@/org/springframework/cloud/stream/app/load-generator-source-kafka/@load-generator-source.version@/load-generator-source-kafka-@load-generator-source.version@.jar
 source.load-generator.metadata=https://@repo-spring-io@/org/springframework/cloud/stream/app/load-generator-source-kafka/@load-generator-source.version@/load-generator-source-kafka-@load-generator-source.version@-metadata.jar
+source.mail=https://@repo-spring-io@/org/springframework/cloud/stream/app/mail-source-kafka/@mail-source.version@/mail-source-kafka-@mail-source.version@.jar
+source.mail.metadata=https://@repo-spring-io@/org/springframework/cloud/stream/app/mail-source-kafka/@mail-source.version@/mail-source-kafka-@mail-source.version@-metadata.jar
 source.mongodb=https://@repo-spring-io@/org/springframework/cloud/stream/app/mongodb-source-kafka/@mongodb-source.version@/mongodb-source-kafka-@mongodb-source.version@.jar
 source.mongodb.metadata=https://@repo-spring-io@/org/springframework/cloud/stream/app/mongodb-source-kafka/@mongodb-source.version@/mongodb-source-kafka-@mongodb-source.version@-metadata.jar
 source.mqtt=https://@repo-spring-io@/org/springframework/cloud/stream/app/mqtt-source-kafka/@mqtt-source.version@/mqtt-source-kafka-@mqtt-source.version@.jar
@@ -24,6 +26,8 @@ source.s3=https://@repo-spring-io@/org/springframework/cloud/stream/app/s3-sourc
 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.sftp=https://@repo-spring-io@/org/springframework/cloud/stream/app/sftp-source-kafka/@sftp-source.version@/sftp-source-kafka-@sftp-source.version@.jar
 source.sftp.metadata=https://@repo-spring-io@/org/springframework/cloud/stream/app/sftp-source-kafka/@sftp-source.version@/sftp-source-kafka-@sftp-source.version@-metadata.jar
+source.syslog=https://@repo-spring-io@/org/springframework/cloud/stream/app/syslog-source-kafka/@syslog-source.version@/syslog-source-kafka-@syslog-source.version@.jar
+source.syslog.metadata=https://@repo-spring-io@/org/springframework/cloud/stream/app/syslog-source-kafka/@syslog-source.version@/syslog-source-kafka-@syslog-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
@@ -56,12 +60,16 @@ sink.mongodb=https://@repo-spring-io@/org/springframework/cloud/stream/app/mongo
 sink.mongodb.metadata=https://@repo-spring-io@/org/springframework/cloud/stream/app/mongodb-sink-kafka/@mongodb-sink.version@/mongodb-sink-kafka-@mongodb-sink.version@-metadata.jar
 sink.mqtt=https://@repo-spring-io@/org/springframework/cloud/stream/app/mqtt-sink-kafka/@mqtt-sink.version@/mqtt-sink-kafka-@mqtt-sink.version@.jar
 sink.mqtt.metadata=https://@repo-spring-io@/org/springframework/cloud/stream/app/mqtt-sink-kafka/@mqtt-sink.version@/mqtt-sink-kafka-@mqtt-sink.version@-metadata.jar
+sink.pgcopy=https://@repo-spring-io@/org/springframework/cloud/stream/app/pgcopy-sink-kafka/@pgcopy-sink.version@/pgcopy-sink-kafka-@pgcopy-sink.version@.jar
+sink.pgcopy.metadata=https://@repo-spring-io@/org/springframework/cloud/stream/app/pgcopy-sink-kafka/@pgcopy-sink.version@/pgcopy-sink-kafka-@pgcopy-sink.version@-metadata.jar
 sink.rabbit=https://@repo-spring-io@/org/springframework/cloud/stream/app/rabbit-sink-kafka/@rabbit-sink.version@/rabbit-sink-kafka-@rabbit-sink.version@.jar
 sink.rabbit.metadata=https://@repo-spring-io@/org/springframework/cloud/stream/app/rabbit-sink-kafka/@rabbit-sink.version@/rabbit-sink-kafka-@rabbit-sink.version@-metadata.jar
 sink.redis=https://@repo-spring-io@/org/springframework/cloud/stream/app/redis-sink-kafka/@redis-sink.version@/redis-sink-kafka-@redis-sink.version@.jar
 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.rsocket=https://@repo-spring-io@/org/springframework/cloud/stream/app/rsocket-sink-kafka/@rsocket-sink.version@/rsocket-sink-kafka-@rsocket-sink.version@.jar
+sink.rsocket.metadata=https://@repo-spring-io@/org/springframework/cloud/stream/app/rsocket-sink-kafka/@rsocket-sink.version@/rsocket-sink-kafka-@rsocket-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
@@ -78,6 +86,8 @@ sink.twitter-update=https://@repo-spring-io@/org/springframework/cloud/stream/ap
 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.aggregator=https://@repo-spring-io@/org/springframework/cloud/stream/app/aggregator-processor-kafka/@aggregator-processor.version@/aggregator-processor-kafka-@aggregator-processor.version@.jar
+processor.aggregator.metadata=https://@repo-spring-io@/org/springframework/cloud/stream/app/aggregator-processor-kafka/@aggregator-processor.version@/aggregator-processor-kafka-@aggregator-processor.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
 processor.bridge.metadata=https://@repo-spring-io@/org/springframework/cloud/stream/app/bridge-processor-kafka/@bridge-processor.version@/bridge-processor-kafka-@bridge-processor.version@-metadata.jar
 processor.filter=https://@repo-spring-io@/org/springframework/cloud/stream/app/filter-processor-kafka/@filter-processor.version@/filter-processor-kafka-@filter-processor.version@.jar
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 747b2498..0e95dc37 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
@@ -14,6 +14,8 @@ source.jms=maven://org.springframework.cloud.stream.app:jms-source-kafka:@jms-so
 source.jms.metadata=maven://org.springframework.cloud.stream.app:jms-source-kafka:jar:metadata:@jms-source.version@
 source.load-generator=maven://org.springframework.cloud.stream.app:load-generator-source-kafka:@load-generator-source.version@
 source.load-generator.metadata=maven://org.springframework.cloud.stream.app:load-generator-source-kafka:jar:metadata:@load-generator-source.version@
+source.mail=maven://org.springframework.cloud.stream.app:mail-source-kafka:@mail-source.version@
+source.mail.metadata=maven://org.springframework.cloud.stream.app:mail-source-kafka:jar:metadata:@mail-source.version@
 source.mongodb=maven://org.springframework.cloud.stream.app:mongodb-source-kafka:@mongodb-source.version@
 source.mongodb.metadata=maven://org.springframework.cloud.stream.app:mongodb-source-kafka:jar:metadata:@mongodb-source.version@
 source.mqtt=maven://org.springframework.cloud.stream.app:mqtt-source-kafka:@mqtt-source.version@
@@ -24,6 +26,8 @@ source.s3=maven://org.springframework.cloud.stream.app:s3-source-kafka:@s3-sourc
 source.s3.metadata=maven://org.springframework.cloud.stream.app:s3-source-kafka:jar:metadata:@s3-source.version@
 source.sftp=maven://org.springframework.cloud.stream.app:sftp-source-kafka:@sftp-source.version@
 source.sftp.metadata=maven://org.springframework.cloud.stream.app:sftp-source-kafka:jar:metadata:@sftp-source.version@
+source.syslog=maven://org.springframework.cloud.stream.app:syslog-source-kafka:@syslog-source.version@
+source.syslog.metadata=maven://org.springframework.cloud.stream.app:syslog-source-kafka:jar:metadata:@syslog-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@
@@ -56,12 +60,16 @@ sink.mongodb=maven://org.springframework.cloud.stream.app:mongodb-sink-kafka:@mo
 sink.mongodb.metadata=maven://org.springframework.cloud.stream.app:mongodb-sink-kafka:jar:metadata:@mongodb-sink.version@
 sink.mqtt=maven://org.springframework.cloud.stream.app:mqtt-sink-kafka:@mqtt-sink.version@
 sink.mqtt.metadata=maven://org.springframework.cloud.stream.app:mqtt-sink-kafka:jar:metadata:@mqtt-sink.version@
+sink.pgcopy=maven://org.springframework.cloud.stream.app:pgcopy-sink-kafka:@pgcopy-sink.version@
+sink.pgcopy.metadata=maven://org.springframework.cloud.stream.app:pgcopy-sink-kafka:jar:metadata:@pgcopy-sink.version@
 sink.rabbit=maven://org.springframework.cloud.stream.app:rabbit-sink-kafka:@rabbit-sink.version@
 sink.rabbit.metadata=maven://org.springframework.cloud.stream.app:rabbit-sink-kafka:jar:metadata:@rabbit-sink.version@
 sink.redis=maven://org.springframework.cloud.stream.app:redis-sink-kafka:@redis-sink.version@
 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.rsocket=maven://org.springframework.cloud.stream.app:rsocket-sink-kafka:@rsocket-sink.version@
+sink.rsocket.metadata=maven://org.springframework.cloud.stream.app:rsocket-sink-kafka:jar:metadata:@rsocket-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@
@@ -78,6 +86,8 @@ sink.twitter-update=maven://org.springframework.cloud.stream.app:twitter-update-
 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.aggregator=maven://org.springframework.cloud.stream.app:aggregator-processor-kafka:@aggregator-processor.version@
+processor.aggregator.metadata=maven://org.springframework.cloud.stream.app:aggregator-processor-kafka:jar:metadata:@aggregator-processor.version@
 processor.bridge=maven://org.springframework.cloud.stream.app:bridge-processor-kafka:@bridge-processor.version@
 processor.bridge.metadata=maven://org.springframework.cloud.stream.app:bridge-processor-kafka:jar:metadata:@bridge-processor.version@
 processor.filter=maven://org.springframework.cloud.stream.app:filter-processor-kafka:@filter-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 7e6dee99..55fc8eba 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
@@ -6,11 +6,13 @@ source.http=docker:springcloudstream/http-source-rabbit:@http-source-docker.tag@
 source.jdbc=docker:springcloudstream/jdbc-source-rabbit:@jdbc-source-docker.tag@
 source.jms=docker:springcloudstream/jms-source-rabbit:@jms-source-docker.tag@
 source.load-generator=docker:springcloudstream/load-generator-source-rabbit:@load-generator-source-docker.tag@
+source.mail=docker:springcloudstream/mail-source-rabbit:@mail-source-docker.tag@
 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.sftp=docker:springcloudstream/sftp-source-rabbit:@sftp-source-docker.tag@
+source.syslog=docker:springcloudstream/syslog-source-rabbit:@syslog-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@
@@ -27,9 +29,11 @@ sink.jdbc=docker:springcloudstream/jdbc-sink-rabbit:@jdbc-sink-docker.tag@
 sink.log=docker:springcloudstream/log-sink-rabbit:@log-sink-docker.tag@
 sink.mongodb=docker:springcloudstream/mongodb-sink-rabbit:@mongodb-sink-docker.tag@
 sink.mqtt=docker:springcloudstream/mqtt-sink-rabbit:@mqtt-sink-docker.tag@
+sink.pgcopy=docker:springcloudstream/pgcopy-sink-rabbit:@pgcopy-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.rsocket=docker:springcloudstream/rsocket-sink-rabbit:@rsocket-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.tasklauncher=docker:springcloudstream/tasklauncher-sink-rabbit:@tasklauncher-sink-docker.tag@
@@ -38,6 +42,7 @@ sink.throughput=docker:springcloudstream/throughput-sink-rabbit:@throughput-sink
 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.aggregator=docker:springcloudstream/aggregator-processor-rabbit:@aggregator-processor-docker.tag@
 processor.bridge=docker:springcloudstream/bridge-processor-rabbit:@bridge-processor-docker.tag@
 processor.filter=docker:springcloudstream/filter-processor-rabbit:@filter-processor-docker.tag@
 processor.groovy=docker:springcloudstream/groovy-processor-rabbit:@groovy-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 ecf76ea8..1c3ce33e 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
@@ -14,6 +14,8 @@ source.jms=https://@repo-spring-io@/org/springframework/cloud/stream/app/jms-sou
 source.jms.metadata=https://@repo-spring-io@/org/springframework/cloud/stream/app/jms-source-rabbit/@jms-source.version@/jms-source-rabbit-@jms-source.version@-metadata.jar
 source.load-generator=https://@repo-spring-io@/org/springframework/cloud/stream/app/load-generator-source-rabbit/@load-generator-source.version@/load-generator-source-rabbit-@load-generator-source.version@.jar
 source.load-generator.metadata=https://@repo-spring-io@/org/springframework/cloud/stream/app/load-generator-source-rabbit/@load-generator-source.version@/load-generator-source-rabbit-@load-generator-source.version@-metadata.jar
+source.mail=https://@repo-spring-io@/org/springframework/cloud/stream/app/mail-source-rabbit/@mail-source.version@/mail-source-rabbit-@mail-source.version@.jar
+source.mail.metadata=https://@repo-spring-io@/org/springframework/cloud/stream/app/mail-source-rabbit/@mail-source.version@/mail-source-rabbit-@mail-source.version@-metadata.jar
 source.mongodb=https://@repo-spring-io@/org/springframework/cloud/stream/app/mongodb-source-rabbit/@mongodb-source.version@/mongodb-source-rabbit-@mongodb-source.version@.jar
 source.mongodb.metadata=https://@repo-spring-io@/org/springframework/cloud/stream/app/mongodb-source-rabbit/@mongodb-source.version@/mongodb-source-rabbit-@mongodb-source.version@-metadata.jar
 source.mqtt=https://@repo-spring-io@/org/springframework/cloud/stream/app/mqtt-source-rabbit/@mqtt-source.version@/mqtt-source-rabbit-@mqtt-source.version@.jar
@@ -24,6 +26,8 @@ source.s3=https://@repo-spring-io@/org/springframework/cloud/stream/app/s3-sourc
 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.sftp=https://@repo-spring-io@/org/springframework/cloud/stream/app/sftp-source-rabbit/@sftp-source.version@/sftp-source-rabbit-@sftp-source.version@.jar
 source.sftp.metadata=https://@repo-spring-io@/org/springframework/cloud/stream/app/sftp-source-rabbit/@sftp-source.version@/sftp-source-rabbit-@sftp-source.version@-metadata.jar
+source.syslog=https://@repo-spring-io@/org/springframework/cloud/stream/app/syslog-source-rabbit/@syslog-source.version@/syslog-source-rabbit-@syslog-source.version@.jar
+source.syslog.metadata=https://@repo-spring-io@/org/springframework/cloud/stream/app/syslog-source-rabbit/@syslog-source.version@/syslog-source-rabbit-@syslog-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
@@ -56,12 +60,16 @@ sink.mongodb=https://@repo-spring-io@/org/springframework/cloud/stream/app/mongo
 sink.mongodb.metadata=https://@repo-spring-io@/org/springframework/cloud/stream/app/mongodb-sink-rabbit/@mongodb-sink.version@/mongodb-sink-rabbit-@mongodb-sink.version@-metadata.jar
 sink.mqtt=https://@repo-spring-io@/org/springframework/cloud/stream/app/mqtt-sink-rabbit/@mqtt-sink.version@/mqtt-sink-rabbit-@mqtt-sink.version@.jar
 sink.mqtt.metadata=https://@repo-spring-io@/org/springframework/cloud/stream/app/mqtt-sink-rabbit/@mqtt-sink.version@/mqtt-sink-rabbit-@mqtt-sink.version@-metadata.jar
+sink.pgcopy=https://@repo-spring-io@/org/springframework/cloud/stream/app/pgcopy-sink-rabbit/@pgcopy-sink.version@/pgcopy-sink-rabbit-@pgcopy-sink.version@.jar
+sink.pgcopy.metadata=https://@repo-spring-io@/org/springframework/cloud/stream/app/pgcopy-sink-rabbit/@pgcopy-sink.version@/pgcopy-sink-rabbit-@pgcopy-sink.version@-metadata.jar
 sink.rabbit=https://@repo-spring-io@/org/springframework/cloud/stream/app/rabbit-sink-rabbit/@rabbit-sink.version@/rabbit-sink-rabbit-@rabbit-sink.version@.jar
 sink.rabbit.metadata=https://@repo-spring-io@/org/springframework/cloud/stream/app/rabbit-sink-rabbit/@rabbit-sink.version@/rabbit-sink-rabbit-@rabbit-sink.version@-metadata.jar
 sink.redis=https://@repo-spring-io@/org/springframework/cloud/stream/app/redis-sink-rabbit/@redis-sink.version@/redis-sink-rabbit-@redis-sink.version@.jar
 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.rsocket=https://@repo-spring-io@/org/springframework/cloud/stream/app/rsocket-sink-rabbit/@rsocket-sink.version@/rsocket-sink-rabbit-@rsocket-sink.version@.jar
+sink.rsocket.metadata=https://@repo-spring-io@/org/springframework/cloud/stream/app/rsocket-sink-rabbit/@rsocket-sink.version@/rsocket-sink-rabbit-@rsocket-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
@@ -78,6 +86,8 @@ sink.twitter-update=https://@repo-spring-io@/org/springframework/cloud/stream/ap
 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.aggregator=https://@repo-spring-io@/org/springframework/cloud/stream/app/aggregator-processor-rabbit/@aggregator-processor.version@/aggregator-processor-rabbit-@aggregator-processor.version@.jar
+processor.aggregator.metadata=https://@repo-spring-io@/org/springframework/cloud/stream/app/aggregator-processor-rabbit/@aggregator-processor.version@/aggregator-processor-rabbit-@aggregator-processor.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
 processor.bridge.metadata=https://@repo-spring-io@/org/springframework/cloud/stream/app/bridge-processor-rabbit/@bridge-processor.version@/bridge-processor-rabbit-@bridge-processor.version@-metadata.jar
 processor.filter=https://@repo-spring-io@/org/springframework/cloud/stream/app/filter-processor-rabbit/@filter-processor.version@/filter-processor-rabbit-@filter-processor.version@.jar
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 1a62a1ef..6b7ad14b 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
@@ -14,6 +14,8 @@ source.jms=maven://org.springframework.cloud.stream.app:jms-source-rabbit:@jms-s
 source.jms.metadata=maven://org.springframework.cloud.stream.app:jms-source-rabbit:jar:metadata:@jms-source.version@
 source.load-generator=maven://org.springframework.cloud.stream.app:load-generator-source-rabbit:@load-generator-source.version@
 source.load-generator.metadata=maven://org.springframework.cloud.stream.app:load-generator-source-rabbit:jar:metadata:@load-generator-source.version@
+source.mail=maven://org.springframework.cloud.stream.app:mail-source-rabbit:@mail-source.version@
+source.mail.metadata=maven://org.springframework.cloud.stream.app:mail-source-rabbit:jar:metadata:@mail-source.version@
 source.mongodb=maven://org.springframework.cloud.stream.app:mongodb-source-rabbit:@mongodb-source.version@
 source.mongodb.metadata=maven://org.springframework.cloud.stream.app:mongodb-source-rabbit:jar:metadata:@mongodb-source.version@
 source.mqtt=maven://org.springframework.cloud.stream.app:mqtt-source-rabbit:@mqtt-source.version@
@@ -24,6 +26,8 @@ source.s3=maven://org.springframework.cloud.stream.app:s3-source-rabbit:@s3-sour
 source.s3.metadata=maven://org.springframework.cloud.stream.app:s3-source-rabbit:jar:metadata:@s3-source.version@
 source.sftp=maven://org.springframework.cloud.stream.app:sftp-source-rabbit:@sftp-source.version@
 source.sftp.metadata=maven://org.springframework.cloud.stream.app:sftp-source-rabbit:jar:metadata:@sftp-source.version@
+source.syslog=maven://org.springframework.cloud.stream.app:syslog-source-rabbit:@syslog-source.version@
+source.syslog.metadata=maven://org.springframework.cloud.stream.app:syslog-source-rabbit:jar:metadata:@syslog-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@
@@ -56,12 +60,16 @@ sink.mongodb=maven://org.springframework.cloud.stream.app:mongodb-sink-rabbit:@m
 sink.mongodb.metadata=maven://org.springframework.cloud.stream.app:mongodb-sink-rabbit:jar:metadata:@mongodb-sink.version@
 sink.mqtt=maven://org.springframework.cloud.stream.app:mqtt-sink-rabbit:@mqtt-sink.version@
 sink.mqtt.metadata=maven://org.springframework.cloud.stream.app:mqtt-sink-rabbit:jar:metadata:@mqtt-sink.version@
+sink.pgcopy=maven://org.springframework.cloud.stream.app:pgcopy-sink-rabbit:@pgcopy-sink.version@
+sink.pgcopy.metadata=maven://org.springframework.cloud.stream.app:pgcopy-sink-rabbit:jar:metadata:@pgcopy-sink.version@
 sink.rabbit=maven://org.springframework.cloud.stream.app:rabbit-sink-rabbit:@rabbit-sink.version@
 sink.rabbit.metadata=maven://org.springframework.cloud.stream.app:rabbit-sink-rabbit:jar:metadata:@rabbit-sink.version@
 sink.redis=maven://org.springframework.cloud.stream.app:redis-sink-rabbit:@redis-sink.version@
 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.rsocket=maven://org.springframework.cloud.stream.app:rsocket-sink-rabbit:@rsocket-sink.version@
+sink.rsocket.metadata=maven://org.springframework.cloud.stream.app:rsocket-sink-rabbit:jar:metadata:@rsocket-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@
@@ -78,6 +86,8 @@ sink.twitter-update=maven://org.springframework.cloud.stream.app:twitter-update-
 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.aggregator=maven://org.springframework.cloud.stream.app:aggregator-processor-rabbit:@aggregator-processor.version@
+processor.aggregator.metadata=maven://org.springframework.cloud.stream.app:aggregator-processor-rabbit:jar:metadata:@aggregator-processor.version@
 processor.bridge=maven://org.springframework.cloud.stream.app:bridge-processor-rabbit:@bridge-processor.version@
 processor.bridge.metadata=maven://org.springframework.cloud.stream.app:bridge-processor-rabbit:jar:metadata:@bridge-processor.version@
 processor.filter=maven://org.springframework.cloud.stream.app:filter-processor-rabbit:@filter-processor.version@
@@ -88,6 +98,8 @@ processor.header-enricher=maven://org.springframework.cloud.stream.app:header-en
 processor.header-enricher.metadata=maven://org.springframework.cloud.stream.app:header-enricher-processor-rabbit:jar:metadata:@header-enricher-processor.version@
 processor.http-request=maven://org.springframework.cloud.stream.app:http-request-processor-rabbit:@http-request-processor.version@
 processor.http-request.metadata=maven://org.springframework.cloud.stream.app:http-request-processor-rabbit:jar:metadata:@http-request-processor.version@
+processor.image-recognition=maven://org.springframework.cloud.stream.app:image-recognition-processor-rabbit:@image-recognition-processor.version@
+processor.image-recognition.metadata=maven://org.springframework.cloud.stream.app:image-recognition-processor-rabbit:jar:metadata:@image-recognition-processor.version@
 processor.object-detection=maven://org.springframework.cloud.stream.app:object-detection-processor-rabbit:@object-detection-processor.version@
 processor.object-detection.metadata=maven://org.springframework.cloud.stream.app:object-detection-processor-rabbit:jar:metadata:@object-detection-processor.version@
 processor.semantic-segmentation=maven://org.springframework.cloud.stream.app:semantic-segmentation-processor-rabbit:@semantic-segmentation-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 0ff7e29d..b94c7463 100644
--- a/applications/stream-applications-build/stream-applications-docs/pom.xml
+++ b/applications/stream-applications-build/stream-applications-docs/pom.xml
@@ -102,6 +102,11 @@
 			<artifactId>jms-supplier</artifactId>
 			<version>${java-functions.version}</version>
 		</dependency>
+		<dependency>
+			<groupId>org.springframework.cloud.fn</groupId>
+			<artifactId>mail-supplier</artifactId>
+			<version>${java-functions.version}</version>
+		</dependency>
 		<dependency>
 			<groupId>org.springframework.cloud.fn</groupId>
 			<artifactId>mongodb-supplier</artifactId>
@@ -127,6 +132,11 @@
 			<artifactId>sftp-supplier</artifactId>
 			<version>${java-functions.version}</version>
 		</dependency>
+		<dependency>
+			<groupId>org.springframework.cloud.fn</groupId>
+			<artifactId>syslog-supplier</artifactId>
+			<version>${java-functions.version}</version>
+		</dependency>
 		<dependency>
 			<groupId>org.springframework.cloud.fn</groupId>
 			<artifactId>tcp-supplier</artifactId>
@@ -208,6 +218,11 @@
 			<artifactId>redis-consumer</artifactId>
 			<version>${java-functions.version}</version>
 		</dependency>
+		<dependency>
+			<groupId>org.springframework.cloud.fn</groupId>
+			<artifactId>rsocket-consumer</artifactId>
+			<version>${java-functions.version}</version>
+		</dependency>
 		<dependency>
 			<groupId>org.springframework.cloud.fn</groupId>
 			<artifactId>s3-consumer</artifactId>
@@ -234,6 +249,11 @@
 			<version>${java-functions.version}</version>
 		</dependency>
 		<!-- function javadocs -->
+		<dependency>
+			<groupId>org.springframework.cloud.fn</groupId>
+			<artifactId>aggregator-function</artifactId>
+			<version>${java-functions.version}</version>
+		</dependency>
 		<dependency>
 			<groupId>org.springframework.cloud.fn</groupId>
 			<artifactId>header-enricher-function</artifactId>
@@ -290,6 +310,11 @@
 			<artifactId>router-sink</artifactId>
 			<version>${router-sink.version}</version>
 		</dependency>
+		<dependency>
+			<groupId>org.springframework.cloud.stream.app</groupId>
+			<artifactId>pgcopy-sink</artifactId>
+			<version>${pgcopy-sink.version}</version>
+		</dependency>
 		<dependency>
 			<groupId>org.springframework.cloud.stream.app</groupId>
 			<artifactId>throughput-sink</artifactId>