Skip to content

Commit

Permalink
Update the S3 source connector to use a later version of Kafka (#383)
Browse files Browse the repository at this point in the history
Previously this was on Version 1.1.0 and upgrading to be on version
3.3.0.

This will allow us in the future to use the exactly once kip that was
introduced in 3.3.0 without causing any upgrade path issues for users.

Signed-off-by: Aindriu Lavelle <aindriu.lavelle@aiven.io>
  • Loading branch information
aindriu-aiven authored Jan 20, 2025
1 parent 6b967d3 commit 343f23c
Showing 1 changed file with 11 additions and 11 deletions.
22 changes: 11 additions & 11 deletions s3-source-connector/build.gradle.kts
Original file line number Diff line number Diff line change
Expand Up @@ -21,7 +21,7 @@ plugins { id("aiven-apache-kafka-connectors-all.java-conventions") }
val amazonS3Version by extra("2.29.34")
val amazonSTSVersion by extra("2.29.34")
val s3mockVersion by extra("0.2.6")
val testKafkaVersion by extra("3.7.1")
val kafkaVersion by extra("3.3.0")

val integrationTest: SourceSet =
sourceSets.create("integrationTest") {
Expand Down Expand Up @@ -62,8 +62,8 @@ idea {
}

dependencies {
compileOnly(apache.kafka.connect.api)
compileOnly(apache.kafka.connect.runtime)
compileOnly("org.apache.kafka:connect-api:$kafkaVersion")
compileOnly("org.apache.kafka:connect-runtime:$kafkaVersion")

implementation(apache.commons.collection4)
implementation(project(":commons"))
Expand All @@ -81,9 +81,9 @@ dependencies {
testImplementation(compressionlibs.snappy)
testImplementation(compressionlibs.zstd.jni)

testImplementation(apache.kafka.connect.api)
testImplementation(apache.kafka.connect.runtime)
testImplementation(apache.kafka.connect.json)
testImplementation("org.apache.kafka:connect-api:$kafkaVersion")
testImplementation("org.apache.kafka:connect-runtime:$kafkaVersion")
testImplementation("org.apache.kafka:connect-json:$kafkaVersion")

testImplementation(testinglibs.junit.jupiter)
testImplementation(testinglibs.assertj.core)
Expand Down Expand Up @@ -184,11 +184,11 @@ dependencies {
exclude(group = "io.netty", module = "netty")
}

integrationTestImplementation("org.apache.kafka:connect-runtime:${testKafkaVersion}:test")
integrationTestImplementation("org.apache.kafka:connect-runtime:${testKafkaVersion}")
integrationTestImplementation("org.apache.kafka:kafka-clients:${testKafkaVersion}:test")
integrationTestImplementation("org.apache.kafka:kafka_2.13:${testKafkaVersion}:test")
integrationTestImplementation("org.apache.kafka:kafka_2.13:${testKafkaVersion}")
integrationTestImplementation("org.apache.kafka:connect-runtime:${kafkaVersion}:test")
integrationTestImplementation("org.apache.kafka:connect-runtime:${kafkaVersion}")
integrationTestImplementation("org.apache.kafka:kafka-clients:${kafkaVersion}:test")
integrationTestImplementation("org.apache.kafka:kafka_2.13:${kafkaVersion}:test")
integrationTestImplementation("org.apache.kafka:kafka_2.13:${kafkaVersion}")

// Make test utils from 'test' available in 'integration-test'
integrationTestImplementation(sourceSets["test"].output)
Expand Down

0 comments on commit 343f23c

Please sign in to comment.