SpringCloud/spring-cloud-dataflow-samples
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

Update multi IO samples based on the maven plugin update

Browse Source
This commit is contained in:
Ilayaperumal Gopinathan
2020-08-21 15:31:37 +05:30
parent 0c89fc6088
commit a392325fe1
10 changed files with 65 additions and 18 deletions
Download Patch File Download Diff File Expand all files Collapse all files

7
multi-io-samples/kafka-streams/user-clicks-per-region/http-click-ingest/pom.xml
View File

@@ -162,7 +162,7 @@
<org.springframework.cloud.dataflow.spring-configuration-metadata.json>
${org.springframework.cloud.dataflow.spring.configuration.metadata.json}
</org.springframework.cloud.dataflow.spring-configuration-metadata.json>
<configuration-properties.outbound-ports>user-clicks</configuration-properties.outbound-ports>
<configuration-properties.outbound-ports>${configuration-properties.outbound-ports}</configuration-properties.outbound-ports>
</labels>
</container>
</configuration>
@@ -182,6 +182,9 @@
<file>
${project.build.outputDirectory}/META-INF/spring-configuration-metadata-encoded.properties
</file>
<file>
${project.build.outputDirectory}/META-INF/dataflow-configuration-port-mapping.properties
</file>
</files>
</configuration>
</execution>
@@ -190,7 +193,7 @@
<plugin>
<groupId>org.springframework.cloud</groupId>
<artifactId>spring-cloud-app-starter-metadata-maven-plugin</artifactId>
<version>2.0.1.M1</version>
<version>2.0.2.BUILD-SNAPSHOT</version>
<configuration>
<storeFilteredMetadata>true</storeFilteredMetadata>
<metadataFilter>

7
multi-io-samples/kafka-streams/user-clicks-per-region/http-region-ingest/pom.xml
View File

@@ -160,7 +160,7 @@
<org.springframework.cloud.dataflow.spring-configuration-metadata.json>
${org.springframework.cloud.dataflow.spring.configuration.metadata.json}
</org.springframework.cloud.dataflow.spring-configuration-metadata.json>
<configuration-properties.outbound-ports>user-regions</configuration-properties.outbound-ports>
<configuration-properties.outbound-ports>${configuration-properties.outbound-ports}</configuration-properties.outbound-ports>
</labels>
</container>
</configuration>
@@ -180,6 +180,9 @@
<file>
${project.build.outputDirectory}/META-INF/spring-configuration-metadata-encoded.properties
</file>
<file>
${project.build.outputDirectory}/META-INF/dataflow-configuration-port-mapping.properties
</file>
</files>
</configuration>
</execution>
@@ -188,7 +191,7 @@
<plugin>
<groupId>org.springframework.cloud</groupId>
<artifactId>spring-cloud-app-starter-metadata-maven-plugin</artifactId>
<version>2.0.1.M1</version>
<version>2.0.2.BUILD-SNAPSHOT</version>
<configuration>
<storeFilteredMetadata>true</storeFilteredMetadata>
<metadataFilter>

40
multi-io-samples/kafka-streams/user-clicks-per-region/user-clicks-per-region-processor/pom.xml
View File

@@ -141,7 +141,7 @@
<image>springcloud/openjdk</image>
</from>
<to>
<image>springcloudstream/multi-io-sample-${project.artifactId}</image>
<image>ilayaperumalg/multi-io-sample-${project.artifactId}</image>
<tags>
<tag>1.0.0-SNAPSHOT</tag>
</tags>
@@ -150,12 +150,46 @@
<creationTime>USE_CURRENT_TIMESTAMP</creationTime>
<format>Docker</format>
<labels>
<configuration-properties.inbound-ports>userClicks,userRegions</configuration-properties.inbound-ports>
<configuration-properties.outbound-ports>clicksPerRegion</configuration-properties.outbound-ports>
<configuration-properties.inbound-ports>${configuration-properties.inbound-ports}</configuration-properties.inbound-ports>
<configuration-properties.outbound-ports>${configuration-properties.outbound-ports}</configuration-properties.outbound-ports>
</labels>
</container>
</configuration>
</plugin>
<plugin>
<groupId>org.springframework.cloud</groupId>
<artifactId>spring-cloud-app-starter-metadata-maven-plugin</artifactId>
<version>2.0.2.BUILD-SNAPSHOT</version>
<executions>
<execution>
<id>aggregate-metadata</id>
<phase>compile</phase>
<goals>
<goal>aggregate-metadata</goal>
</goals>
</execution>
</executions>
</plugin>
<plugin>
<groupId>org.codehaus.mojo</groupId>
<artifactId>properties-maven-plugin</artifactId>
<version>1.0.0</version>
<executions>
<execution>
<phase>process-classes</phase>
<goals>
<goal>read-project-properties</goal>
</goals>
<configuration>
<files>
<file>
${project.build.outputDirectory}/META-INF/dataflow-configuration-port-mapping.properties
</file>
</files>
</configuration>
</execution>
</executions>
</plugin>
</plugins>
</build>

2
multi-io-samples/kafka-streams/user-clicks-per-region/user-clicks-per-region-processor/src/main/resources/META-INF/dataflow-configuration-metadata-whitelist.properties
View File

@@ -1,2 +0,0 @@
configuration-properties.inbound-ports=userClicks,userRegions
configuration-properties.outbound-ports=clicksPerRegion

19
multi-io-samples/kafka-streams/user-clicks-per-region/user-clicks-per-region-processor/src/main/resources/application.yml
View File

@@ -1,7 +1,18 @@
spring.cloud.function.definition: processUserClickStream
spring.cloud.stream.function.bindings.processUserClickStream-in-0: userClicks
spring.cloud.stream.function.bindings.processUserClickStream-in-1: userRegions
spring.cloud.stream.function.bindings.processUserClickStream-out-0: clicksPerRegion
#spring.cloud.function.definition: processUserClickStream
#spring.cloud.stream.function.bindings.processUserClickStream-in-0: userClicks
#spring.cloud.stream.function.bindings.processUserClickStream-in-1: userRegions
#spring.cloud.stream.function.bindings.processUserClickStream-out-0: clicksPerRegion
spring:
cloud:
function:
definition: processUserClickStream
stream:
function:
bindings:
processUserClickStream-in-0: userClicks
processUserClickStream-in-1: userRegions
processUserClickStream-out-0: clicksPerRegion
spring.cloud.stream.bindings.userClicks.consumer.useNativeDecoding: true
spring.cloud.stream.bindings.userRegions.consumer.useNativeDecoding: true

2
multi-io-samples/ticktock/multi-input-log-kafka/pom.xml
View File

@@ -247,7 +247,7 @@
<plugin>
<groupId>org.springframework.cloud</groupId>
<artifactId>spring-cloud-app-starter-metadata-maven-plugin</artifactId>
<version>2.0.1.M1</version>
<version>2.0.2.BUILD-SNAPSHOT</version>
<configuration>
<storeFilteredMetadata>true</storeFilteredMetadata>
<metadataFilter>

1
multi-io-samples/ticktock/multi-input-log-kafka/src/main/resources/META-INF/dataflow-configuration-metadata-whitelist.properties → multi-io-samples/ticktock/multi-input-log-kafka/src/main/resources/META-INF/dataflow-configuration-metadata.properties
View File

@@ -1,2 +1 @@
configuration-properties.classes=org.springframework.cloud.fn.consumer.log.LogConsumerProperties
configuration-properties.inbound-ports=input1,input2,input3

2
multi-io-samples/ticktock/multi-input-log-kafka/src/main/resources/application.properties
View File

@@ -4,7 +4,7 @@ info.app.description=@project.description@
info.app.version=@project.version@
management.endpoints.web.exposure.include=health,info,bindings
spring.cloud.stream.function.definition=byteArrayTextToString|logConsumer;byteArrayTextToString|logConsumer2;byteArrayTextToString|logConsumer3
spring.cloud.stream.function.definition=byteArrayTextToString|logConsumer
spring.cloud.stream.function.bindings.byteArrayTextToString|logConsumer-in-0=input1
spring.cloud.stream.function.bindings.byteArrayTextToString|logConsumer2-in-0=input2

2
multi-io-samples/ticktock/multi-input-log-rabbit/pom.xml
View File

@@ -247,7 +247,7 @@
<plugin>
<groupId>org.springframework.cloud</groupId>
<artifactId>spring-cloud-app-starter-metadata-maven-plugin</artifactId>
<version>2.0.1.M1</version>
<version>2.0.2.BUILD-SNAPSHOT</version>
<configuration>
<storeFilteredMetadata>true</storeFilteredMetadata>
<metadataFilter>

1
multi-io-samples/ticktock/multi-input-log-rabbit/src/main/resources/META-INF/dataflow-configuration-metadata-whitelist.properties
View File

@@ -1,2 +1 @@
configuration-properties.classes=org.springframework.cloud.fn.consumer.log.LogConsumerProperties
configuration-properties.inbound-ports=input1,input2,input3