diff --git a/README.md b/README.md index 542f9aa..705553c 100644 --- a/README.md +++ b/README.md @@ -6,6 +6,13 @@ Please check out the blog posts for more details. * [Kotlin Kafka Streams](https://perkss.github.io/#/DistributedSystems/Streaming#KafkaStreamsKotlin) +## Building Locally +As the integration tests run with docker you are required to have docker running locally. + +Then simply execute the maven command you wish. + +`mvn clean install` + ## Docker Environment Please use the docker-compose file in the root of each module project to create the Kafka Brokers and Zookeeper and diff --git a/kafka-reactive-producer-consumer/src/test/kotlin/com/perkss/kafka/reactive/FlowTest.kt b/kafka-reactive-producer-consumer/src/test/kotlin/com/perkss/kafka/reactive/FlowTest.kt index da616d4..f60a6c8 100644 --- a/kafka-reactive-producer-consumer/src/test/kotlin/com/perkss/kafka/reactive/FlowTest.kt +++ b/kafka-reactive-producer-consumer/src/test/kotlin/com/perkss/kafka/reactive/FlowTest.kt @@ -43,7 +43,7 @@ class FlowTest { @BeforeAll @JvmStatic internal fun beforeAll() { - val imageName = DockerImageName.parse("confluentinc/cp-kafka:7.5.3") + val imageName = DockerImageName.parse("confluentinc/cp-kafka:7.7.1") kafkaContainer = KafkaContainer(imageName) kafkaContainer.start() await until { kafkaContainer.isRunning } diff --git a/kotlin-kafka-streams-examples/src/test/kotlin/com/perkss/kafka/reactive/integration/StreamIntegrationTest.kt b/kotlin-kafka-streams-examples/src/test/kotlin/com/perkss/kafka/reactive/integration/StreamIntegrationTest.kt index 700994f..60763e8 100644 --- a/kotlin-kafka-streams-examples/src/test/kotlin/com/perkss/kafka/reactive/integration/StreamIntegrationTest.kt +++ b/kotlin-kafka-streams-examples/src/test/kotlin/com/perkss/kafka/reactive/integration/StreamIntegrationTest.kt @@ -57,8 +57,8 @@ internal class StreamIntegrationTest @Autowired constructor( @BeforeAll @JvmStatic internal fun beforeAll() { - val kafkaImageName = DockerImageName.parse("confluentinc/cp-kafka:7.5.3") - val schemaRegistryImageName = DockerImageName.parse("confluentinc/cp-schema-registry:7.5.3") + val kafkaImageName = DockerImageName.parse("confluentinc/cp-kafka:7.7.1") + val schemaRegistryImageName = DockerImageName.parse("confluentinc/cp-schema-registry:7.7.1") kafka = KafkaContainer(kafkaImageName) kafka.apply { withNetwork(Network.newNetwork()) diff --git a/pom.xml b/pom.xml index 930a98c..d874f8c 100644 --- a/pom.xml +++ b/pom.xml @@ -25,11 +25,11 @@ official 1.9.22 - 1.3.22 - 3.2.1 - 3.6.1 - 7.5.1 - 1.11.3 + 1.3.23 + 3.3.4 + 3.8.0 + 7.7.1 + 1.12.0 5.10.1 5.10.1 @@ -78,12 +78,12 @@ ch.qos.logback logback-classic - 1.3.14 + 1.5.8 ch.qos.logback logback-core - 1.3.14 + 1.5.8 org.codehaus.groovy