More things (#17)

* More things

* Update java and kotlin

Author: rogervinas

.github/workflows/gradle.yml

@@ -16,7 +16,7 @@ jobs:
       - name: Set up Java
         uses: actions/setup-java@v3
         with:
-          java-version: 11
+          java-version: '17'
           distribution: 'temurin'
       - name: Gradle cache
         uses: actions/cache@v3

README.md

@@ -1,6 +1,6 @@
 [![CI](https://github.com/rogervinas/spring-cloud-stream-kafka-streams-processor/actions/workflows/gradle.yml/badge.svg?branch=master)](https://github.com/rogervinas/spring-cloud-stream-kafka-streams-processor/actions/workflows/gradle.yml)
-![Java](https://img.shields.io/badge/Java-11-blue?labelColor=black)
-![Kotlin](https://img.shields.io/badge/Kotlin-1.6.21-blue?labelColor=black)
+![Java](https://img.shields.io/badge/Java-17-blue?labelColor=black)
+![Kotlin](https://img.shields.io/badge/Kotlin-1.9.21-blue?labelColor=black)
 ![SpringBoot](https://img.shields.io/badge/SpringBoot-2.7.8-blue?labelColor=black)
 ![SpringCloud](https://img.shields.io/badge/SpringCloud-2021.0.8-blue?labelColor=black)
 

build.gradle.kts

@@ -5,19 +5,20 @@ import org.jetbrains.kotlin.gradle.tasks.KotlinCompile
 plugins {
   id("org.springframework.boot") version "2.7.8"
   id("io.spring.dependency-management") version "1.0.15.RELEASE"
-  kotlin("jvm") version "1.6.21"
-  kotlin("plugin.spring") version "1.6.21"
+  kotlin("jvm") version "1.9.21"
+  kotlin("plugin.spring") version "1.9.21"
 }
 
 group = "com.rogervinas"
 version = "0.0.1-SNAPSHOT"
-java.sourceCompatibility = JavaVersion.VERSION_11
+java.sourceCompatibility = JavaVersion.VERSION_17
 
 repositories {
   mavenCentral()
 }
 
 val springCloudVersion = "2021.0.8"
+val testContainersVersion = "1.19.3"
 
 dependencies {
   implementation("org.jetbrains.kotlin:kotlin-reflect")
@@ -31,7 +32,9 @@ dependencies {
 
   testImplementation("org.springframework.boot:spring-boot-starter-test")
   testImplementation("org.apache.kafka:kafka-streams-test-utils")
-  testImplementation("org.testcontainers:junit-jupiter:1.19.3")
+
+  testImplementation("org.testcontainers:junit-jupiter:$testContainersVersion")
+  testImplementation("org.testcontainers:testcontainers:$testContainersVersion")
 }
 
 dependencyManagement {
@@ -43,7 +46,7 @@ dependencyManagement {
 tasks.withType<KotlinCompile> {
   kotlinOptions {
     freeCompilerArgs = listOf("-Xjsr305=strict")
-    jvmTarget = "11"
+    jvmTarget = "17"
   }
 }
 

src/main/resources/application.yml

@@ -2,12 +2,14 @@ spring:
   application:
     name: "spring-cloud-stream-kafka-streams-processor"
   cloud:
+    function:
+      definition: userStateStream
     stream:
-      function:
-        definition: userStateStream
-        bindings:
-          userStateStream-in-0: "pub.user.token"
-          userStateStream-out-0: "pub.user.state"
+      bindings:
+        userStateStream-in-0:
+          destination: "pub.user.token"
+        userStateStream-out-0:
+          destination: "pub.user.state"
       kafka:
         streams:
           binder:

src/test/kotlin/com/rogervinas/kafkastreams/stream/UserStreamTest.kt

@@ -18,18 +18,20 @@ import java.time.Duration
 import java.util.Properties
 import java.util.function.Consumer
 
-private const val TOPIC_IN = "topic.in"
-private const val TOPIC_OUT = "topic.out"
+class UserStreamTest {
 
-private const val USERNAME_1 = "user1"
-private const val USERNAME_2 = "user2"
-private const val USERNAME_3 = "user3"
-private const val USERNAME_4 = "user4"
+  companion object {
+    private const val TOPIC_IN = "topic.in"
+    private const val TOPIC_OUT = "topic.out"
 
-private val SCHEDULE = Duration.ofSeconds(1)
-private val EXPIRATION = Duration.ofSeconds(5)
+    private const val USERNAME_1 = "user1"
+    private const val USERNAME_2 = "user2"
+    private const val USERNAME_3 = "user3"
+    private const val USERNAME_4 = "user4"
 
-class UserStreamTest {
+    private val SCHEDULE = Duration.ofSeconds(1)
+    private val EXPIRATION = Duration.ofSeconds(5)
+  }
 
   private lateinit var topologyTestDriver: TopologyTestDriver
   private lateinit var topicIn: TestInputTopic<String, UserTokenEvent>