Skip to content
Open
Show file tree
Hide file tree
Changes from all commits
Commits
File filter

Filter by extension

Filter by extension


Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
7 changes: 7 additions & 0 deletions .gitignore
Original file line number Diff line number Diff line change
Expand Up @@ -27,3 +27,10 @@ dump.rdb
.apt_generated
artifacts
.vscode

# Gradle
.gradle/
build/
!gradle/wrapper/gradle-wrapper.jar
!**/src/main/**/build/
!**/src/test/**/build/
12 changes: 12 additions & 0 deletions batch-producer-consumer/build.gradle.kts
Original file line number Diff line number Diff line change
@@ -0,0 +1,12 @@
plugins {
alias(libs.plugins.spring.boot)
}

dependencies {
implementation(platform(libs.spring.cloud.dependencies))
implementation(libs.spring.cloud.stream)
implementation(libs.spring.cloud.stream.binder.kafka)
implementation(libs.spring.kafka)
testImplementation(libs.spring.cloud.stream.test.binder)
testImplementation(libs.spring.kafka.test)
}
77 changes: 0 additions & 77 deletions batch-producer-consumer/pom.xml
Original file line number Diff line number Diff line change
Expand Up @@ -16,7 +16,6 @@
<description>Sample app using stream functions with batch producer and consumer using kafka</description>
<properties>
<java.version>17</java.version>
<spring-cloud.version>2023.0.0-SNAPSHOT</spring-cloud.version>
</properties>
<dependencies>
<dependency>
Expand Down Expand Up @@ -48,18 +47,6 @@
<scope>test</scope>
</dependency>
</dependencies>
<dependencyManagement>
<dependencies>
<dependency>
<groupId>org.springframework.cloud</groupId>
<artifactId>spring-cloud-dependencies</artifactId>
<version>${spring-cloud.version}</version>
<type>pom</type>
<scope>import</scope>
</dependency>
</dependencies>
</dependencyManagement>

<build>
<plugins>
<plugin>
Expand All @@ -79,69 +66,5 @@
</plugins>
</build>

<repositories>
<repository>
<id>spring-snapshots</id>
<name>Spring Snapshots</name>
<url>https://repo.spring.io/libs-snapshot-local</url>
<snapshots>
<enabled>true</enabled>
</snapshots>
<releases>
<enabled>false</enabled>
</releases>
</repository>
<repository>
<id>spring-milestones</id>
<name>Spring Milestones</name>
<url>https://repo.spring.io/libs-milestone-local</url>
<snapshots>
<enabled>false</enabled>
</snapshots>
</repository>
<repository>
<id>spring-releases</id>
<name>Spring Releases</name>
<url>https://repo.spring.io/release</url>
<snapshots>
<enabled>false</enabled>
</snapshots>
</repository>
<repository>
<id>confluent</id>
<url>https://packages.confluent.io/maven/</url>
</repository>
</repositories>

<pluginRepositories>
<pluginRepository>
<id>spring-snapshots</id>
<name>Spring Snapshots</name>
<url>https://repo.spring.io/libs-snapshot-local</url>
<snapshots>
<enabled>true</enabled>
</snapshots>
<releases>
<enabled>false</enabled>
</releases>
</pluginRepository>
<pluginRepository>
<id>spring-milestones</id>
<name>Spring Milestones</name>
<url>https://repo.spring.io/libs-milestone-local</url>
<snapshots>
<enabled>false</enabled>
</snapshots>
</pluginRepository>
<pluginRepository>
<id>spring-releases</id>
<name>Spring Releases</name>
<url>https://repo.spring.io/libs-release-local</url>
<snapshots>
<enabled>false</enabled>
</snapshots>
</pluginRepository>
</pluginRepositories>


</project>
66 changes: 66 additions & 0 deletions build.gradle.kts
Original file line number Diff line number Diff line change
@@ -0,0 +1,66 @@
plugins {
alias(libs.plugins.spring.boot) apply false
alias(libs.plugins.spring.dependency.management) apply false
alias(libs.plugins.kotlin.jvm) apply false
alias(libs.plugins.kotlin.spring) apply false
}

val aggregatorModules = setOf(
"confluent-schema-registry-integration",
"function-based-stream-app-samples",
"image-thumbnail-samples",
"image-thumbnail-stream-sample",
"couchbase-stream-applications",
"kafka-e2e-kotlin-sample",
"kafka-security-samples",
"kafka-streams-samples",
"kinesis-samples",
"multi-functions-samples",
"multi-binder-samples",
"partitioning-samples",
"kafka-partitioning",
"rabbit-partitioning",
"routing-samples",
"spring-cloud-stream-schema-registry-integration",
"testing-samples",
"transaction-kafka-samples",
)

allprojects {
group = "io.spring.cloud.stream.sample"
version = "0.0.1-SNAPSHOT"
}

subprojects {
if (name in aggregatorModules) return@subprojects

apply(plugin = "java")
apply(plugin = "io.spring.dependency-management")

val catalog = rootProject.the<VersionCatalogsExtension>().named("libs")

the<io.spring.gradle.dependencymanagement.dsl.DependencyManagementExtension>().apply {
imports {
mavenBom("org.springframework.boot:spring-boot-dependencies:${catalog.findVersion("spring-boot").get()}")
mavenBom(catalog.findLibrary("spring-cloud-dependencies").get().get().toString())
}
}

configure<JavaPluginExtension> {
toolchain {
languageVersion = JavaLanguageVersion.of(17)
}
}

dependencies {
"implementation"(catalog.findLibrary("spring-boot-starter").get())
"implementation"(catalog.findLibrary("spring-boot-starter-actuator").get())
"implementation"(catalog.findLibrary("spring-boot-starter-webmvc").get())
"implementation"(catalog.findLibrary("spring-boot-jackson2").get())
"testImplementation"(catalog.findLibrary("spring-boot-starter-test").get())
}

tasks.withType<Test> {
useJUnitPlatform()
}
}
1 change: 1 addition & 0 deletions confluent-schema-registry-integration/build.gradle.kts
Original file line number Diff line number Diff line change
@@ -0,0 +1 @@
// Aggregator module — no build configuration needed
Original file line number Diff line number Diff line change
@@ -0,0 +1,22 @@
plugins {
alias(libs.plugins.spring.boot)
alias(libs.plugins.avro.gradle)
}

avro {
setStringType("String")
}

tasks.named<com.github.davidmc24.gradle.plugin.avro.GenerateAvroJavaTask>("generateAvroJava") {
source("src/main/resources/avro")
}

dependencies {
implementation(libs.spring.cloud.stream.binder.kafka)
implementation(libs.avro)
implementation(libs.confluent.kafka.avro.serializer) {
exclude(group = "org.slf4j", module = "slf4j-api")
exclude(group = "org.slf4j", module = "slf4j-log4j12")
}
implementation(libs.confluent.kafka.schema.registry.client)
}
Original file line number Diff line number Diff line change
@@ -0,0 +1,22 @@
plugins {
alias(libs.plugins.spring.boot)
alias(libs.plugins.avro.gradle)
}

avro {
setStringType("String")
}

tasks.named<com.github.davidmc24.gradle.plugin.avro.GenerateAvroJavaTask>("generateAvroJava") {
source("src/main/resources/avro")
}

dependencies {
implementation(libs.spring.cloud.stream.binder.kafka)
implementation(libs.avro)
implementation(libs.confluent.kafka.avro.serializer) {
exclude(group = "org.slf4j", module = "slf4j-api")
exclude(group = "org.slf4j", module = "slf4j-log4j12")
}
implementation(libs.confluent.kafka.schema.registry.client)
}
Original file line number Diff line number Diff line change
@@ -0,0 +1,22 @@
plugins {
alias(libs.plugins.spring.boot)
alias(libs.plugins.avro.gradle)
}

avro {
setStringType("String")
}

tasks.named<com.github.davidmc24.gradle.plugin.avro.GenerateAvroJavaTask>("generateAvroJava") {
source("src/main/resources/avro")
}

dependencies {
implementation(libs.spring.cloud.stream.binder.kafka)
implementation(libs.avro)
implementation(libs.confluent.kafka.avro.serializer) {
exclude(group = "org.slf4j", module = "slf4j-api")
exclude(group = "org.slf4j", module = "slf4j-log4j12")
}
implementation(libs.confluent.kafka.schema.registry.client)
}
65 changes: 1 addition & 64 deletions confluent-schema-registry-integration/pom.xml
Original file line number Diff line number Diff line change
Expand Up @@ -55,7 +55,7 @@
<dependencies>
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-web</artifactId>
<artifactId>spring-boot-starter-webmvc</artifactId>
</dependency>
<dependency>
<groupId>org.springframework.cloud</groupId>
Expand Down Expand Up @@ -88,68 +88,5 @@
</dependency>
</dependencies>

<repositories>
<repository>
<id>spring-snapshots</id>
<name>Spring Snapshots</name>
<url>https://repo.spring.io/libs-snapshot-local</url>
<snapshots>
<enabled>true</enabled>
</snapshots>
<releases>
<enabled>false</enabled>
</releases>
</repository>
<repository>
<id>spring-milestones</id>
<name>Spring Milestones</name>
<url>https://repo.spring.io/libs-milestone-local</url>
<snapshots>
<enabled>false</enabled>
</snapshots>
</repository>
<repository>
<id>spring-releases</id>
<name>Spring Releases</name>
<url>https://repo.spring.io/release</url>
<snapshots>
<enabled>false</enabled>
</snapshots>
</repository>
<repository>
<id>confluent</id>
<url>https://packages.confluent.io/maven/</url>
</repository>
</repositories>

<pluginRepositories>
<pluginRepository>
<id>spring-snapshots</id>
<name>Spring Snapshots</name>
<url>https://repo.spring.io/libs-snapshot-local</url>
<snapshots>
<enabled>true</enabled>
</snapshots>
<releases>
<enabled>false</enabled>
</releases>
</pluginRepository>
<pluginRepository>
<id>spring-milestones</id>
<name>Spring Milestones</name>
<url>https://repo.spring.io/libs-milestone-local</url>
<snapshots>
<enabled>false</enabled>
</snapshots>
</pluginRepository>
<pluginRepository>
<id>spring-releases</id>
<name>Spring Releases</name>
<url>https://repo.spring.io/libs-release-local</url>
<snapshots>
<enabled>false</enabled>
</snapshots>
</pluginRepository>
</pluginRepositories>

</project>
1 change: 1 addition & 0 deletions function-based-stream-app-samples/build.gradle.kts
Original file line number Diff line number Diff line change
@@ -0,0 +1 @@
// Aggregator module — no build configuration needed
Original file line number Diff line number Diff line change
@@ -0,0 +1 @@
// Aggregator module — no build configuration needed
Original file line number Diff line number Diff line change
@@ -0,0 +1,26 @@
plugins {
alias(libs.plugins.spring.boot)
}

tasks.named<org.springframework.boot.gradle.tasks.bundling.BootJar>("bootJar") {
enabled = false
}

tasks.named<Jar>("jar") {
enabled = true
}

dependencies {
implementation(libs.couchbase.java.client)
compileOnly(libs.spring.boot.configuration.processor)
annotationProcessor(libs.spring.boot.configuration.processor)
implementation(libs.spring.cloud.fn.config.common)
testImplementation(libs.reactor.test)
testImplementation(libs.testcontainers.couchbase)
testImplementation(libs.testcontainers.junit.jupiter)
}

// Tests require running Couchbase container; Maven also skips tests for this module.
tasks.named("compileTestJava") { enabled = false }
tasks.named("processTestResources") { enabled = false }
tasks.withType<Test> { enabled = false }
Original file line number Diff line number Diff line change
Expand Up @@ -42,14 +42,27 @@
</dependency>
<dependency>
<groupId>org.testcontainers</groupId>
<artifactId>couchbase</artifactId>
<artifactId>testcontainers-couchbase</artifactId>
<scope>test</scope>
</dependency>
<dependency>
<groupId>org.testcontainers</groupId>
<artifactId>junit-jupiter</artifactId>
<artifactId>testcontainers-junit-jupiter</artifactId>
<scope>test</scope>
</dependency>
</dependencies>


<build>
<plugins>
<plugin>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-maven-plugin</artifactId>
<configuration>
<skip>true</skip>
</configuration>
</plugin>
</plugins>
</build>

</project>
Loading