Skip to content

Commit 3881733

Browse files
davetroianodavetroiano
committed
upgrade to AK 4.0 / CP 8.0 dependencies
1 parent 7f85642 commit 3881733

File tree

46 files changed

+176
-142
lines changed

Some content is hidden

Large Commits have some content hidden by default. Use the searchbox below for content that may be hidden.

46 files changed

+176
-142
lines changed

‎aggregating-average/kstreams/build.gradle

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -28,16 +28,16 @@ repositories {
2828
dependencies {
2929
implementation project(':common')
3030
implementation "org.slf4j:slf4j-simple:2.0.7"
31-
implementation 'org.apache.kafka:kafka-streams:3.6.0'
31+
implementation 'org.apache.kafka:kafka-streams:4.0.0'
3232
implementation('org.apache.kafka:kafka-clients') {
3333
version {
34-
strictly '3.6.0'
34+
strictly '4.0.0'
3535
}
3636
}
3737
implementation "io.confluent:kafka-streams-avro-serde:7.5.1"
3838
implementation "com.typesafe:config:1.4.2"
3939

40-
testImplementation "org.apache.kafka:kafka-streams-test-utils:3.6.0"
40+
testImplementation "org.apache.kafka:kafka-streams-test-utils:4.0.0"
4141
testImplementation 'org.junit.jupiter:junit-jupiter-api:5.9.2'
4242
testImplementation 'org.hamcrest:hamcrest:2.2'
4343
testRuntimeOnly 'org.junit.platform:junit-platform-launcher'

‎aggregating-count/kstreams/build.gradle

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -27,16 +27,16 @@ repositories {
2727
dependencies {
2828
implementation project(':common')
2929
implementation "org.slf4j:slf4j-simple:2.0.7"
30-
implementation 'org.apache.kafka:kafka-streams:3.6.0'
30+
implementation 'org.apache.kafka:kafka-streams:4.0.0'
3131
implementation('org.apache.kafka:kafka-clients') {
3232
version {
33-
strictly '3.6.0'
33+
strictly '4.0.0'
3434
}
3535
}
3636
implementation "io.confluent:kafka-streams-avro-serde:7.5.1"
3737
implementation "com.typesafe:config:1.4.2"
3838

39-
testImplementation "org.apache.kafka:kafka-streams-test-utils:3.6.0"
39+
testImplementation "org.apache.kafka:kafka-streams-test-utils:4.0.0"
4040
testImplementation 'org.junit.jupiter:junit-jupiter-api:5.9.2'
4141
testImplementation 'org.hamcrest:hamcrest:2.2'
4242
testRuntimeOnly 'org.junit.platform:junit-platform-launcher'

‎aggregating-minmax/kstreams/build.gradle

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -35,16 +35,16 @@ repositories {
3535
dependencies {
3636
implementation project(':common')
3737
implementation "org.slf4j:slf4j-simple:2.0.7"
38-
implementation 'org.apache.kafka:kafka-streams:3.6.0'
38+
implementation 'org.apache.kafka:kafka-streams:4.0.0'
3939
implementation('org.apache.kafka:kafka-clients') {
4040
version {
41-
strictly '3.6.0'
41+
strictly '4.0.0'
4242
}
4343
}
4444
implementation "io.confluent:kafka-streams-avro-serde:7.5.1"
4545
implementation "com.typesafe:config:1.4.2"
4646

47-
testImplementation "org.apache.kafka:kafka-streams-test-utils:3.6.0"
47+
testImplementation "org.apache.kafka:kafka-streams-test-utils:4.0.0"
4848
testImplementation 'org.junit.jupiter:junit-jupiter-api:5.9.2'
4949
testImplementation 'org.hamcrest:hamcrest:2.2'
5050
testRuntimeOnly 'org.junit.platform:junit-platform-launcher'

‎aggregating-sum/kstreams/build.gradle

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -35,16 +35,16 @@ repositories {
3535
dependencies {
3636
implementation project(':common')
3737
implementation "org.slf4j:slf4j-simple:2.0.7"
38-
implementation 'org.apache.kafka:kafka-streams:3.6.0'
38+
implementation 'org.apache.kafka:kafka-streams:4.0.0'
3939
implementation('org.apache.kafka:kafka-clients') {
4040
version {
41-
strictly '3.6.0'
41+
strictly '4.0.0'
4242
}
4343
}
4444
implementation "io.confluent:kafka-streams-avro-serde:7.5.1"
4545
implementation "com.typesafe:config:1.4.2"
4646

47-
testImplementation "org.apache.kafka:kafka-streams-test-utils:3.6.0"
47+
testImplementation "org.apache.kafka:kafka-streams-test-utils:4.0.0"
4848
testImplementation 'org.junit.jupiter:junit-jupiter-api:5.9.2'
4949
testImplementation 'org.hamcrest:hamcrest:2.2'
5050
testRuntimeOnly 'org.junit.platform:junit-platform-launcher'

‎build.gradle

Lines changed: 4 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -11,6 +11,10 @@
1111
allprojects {
1212
repositories {
1313
mavenCentral()
14+
maven {
15+
url = uri("https://repository.apache.org/content/groups/staging/")
16+
}
17+
maven { url 'https://packages.confluent.io/maven/' }
1418
}
1519
}
1620

‎client-telemetry-reporter-plugin/kafka/build.gradle

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -29,7 +29,7 @@ dependencies {
2929
implementation "io.grpc:grpc-stub:1.66.0"
3030
implementation('org.apache.kafka:kafka-clients') {
3131
version {
32-
strictly '3.8.0'
32+
strictly '4.0.0'
3333
}
3434
}
3535
}

‎cogrouping-streams/kstreams/build.gradle

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -36,16 +36,16 @@ repositories {
3636
dependencies {
3737
implementation project(':common')
3838
implementation "org.slf4j:slf4j-simple:2.0.7"
39-
implementation 'org.apache.kafka:kafka-streams:3.6.0'
39+
implementation 'org.apache.kafka:kafka-streams:4.0.0'
4040
implementation('org.apache.kafka:kafka-clients') {
4141
version {
42-
strictly '3.6.0'
42+
strictly '4.0.0'
4343
}
4444
}
4545
implementation "io.confluent:kafka-streams-avro-serde:7.5.1"
4646
implementation "com.typesafe:config:1.4.2"
4747

48-
testImplementation "org.apache.kafka:kafka-streams-test-utils:3.6.0"
48+
testImplementation "org.apache.kafka:kafka-streams-test-utils:4.0.0"
4949
testImplementation 'org.junit.jupiter:junit-jupiter-api:5.9.2'
5050
testImplementation 'org.hamcrest:hamcrest:2.2'
5151
testRuntimeOnly 'org.junit.platform:junit-platform-launcher'

‎common/build.gradle

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -39,7 +39,7 @@ dependencies {
3939
implementation 'org.slf4j:slf4j-simple:2.0.7'
4040
implementation('org.apache.kafka:kafka-clients') {
4141
version {
42-
strictly '3.7.0'
42+
strictly '4.0.0'
4343
}
4444
}
4545
implementation 'io.confluent:kafka-streams-avro-serde:7.5.1'

‎confluent-parallel-consumer-application/kafka/build.gradle

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -31,7 +31,7 @@ repositories {
3131
dependencies {
3232
implementation project(':common')
3333
implementation "org.slf4j:slf4j-simple:2.0.7"
34-
implementation "io.confluent.parallelconsumer:parallel-consumer-core:0.5.2.4"
34+
implementation "io.confluent.parallelconsumer:parallel-consumer-core:0.5.3.2"
3535
implementation "org.apache.commons:commons-lang3:3.12.0"
3636
implementation "me.tongfei:progressbar:0.9.3"
3737
implementation 'org.awaitility:awaitility:4.2.0'
@@ -41,7 +41,7 @@ dependencies {
4141
testImplementation 'org.junit.jupiter:junit-jupiter-api:5.9.2'
4242
testImplementation 'org.hamcrest:hamcrest:2.2'
4343
testImplementation 'org.awaitility:awaitility:4.2.0'
44-
testImplementation "io.confluent.parallelconsumer:parallel-consumer-core:0.5.2.4:tests" // for LongPollingMockConsumer
44+
testImplementation "io.confluent.parallelconsumer:parallel-consumer-core:0.5.3.2:tests" // for LongPollingMockConsumer
4545
testRuntimeOnly 'org.junit.platform:junit-platform-launcher'
4646
testRuntimeOnly 'org.junit.jupiter:junit-jupiter-engine:5.9.2'
4747
}

‎confluent-parallel-consumer-application/kafka/src/test/java/io/confluent/developer/ParallelConsumerApplicationTest.java

Lines changed: 11 additions & 11 deletions
Original file line numberDiff line numberDiff line change
@@ -61,22 +61,22 @@ public void consumerTest() throws Exception {
6161
expectedRecords.add("baz");
6262
final Set<String> actualRecords = new HashSet<>();
6363
Awaitility.await()
64-
.atMost(5, SECONDS)
65-
.pollInterval(Duration.ofSeconds(1))
66-
.until(() -> {
67-
actualRecords.clear();
68-
actualRecords.addAll(Files.readAllLines(tempFilePath));
69-
return actualRecords.size() == 3;
70-
});
64+
.atMost(5, SECONDS)
65+
.pollInterval(Duration.ofSeconds(1))
66+
.until(() -> {
67+
actualRecords.clear();
68+
actualRecords.addAll(Files.readAllLines(tempFilePath));
69+
return actualRecords.size() == 3;
70+
});
7171
assertEquals(actualRecords, expectedRecords);
7272
}
7373

7474
private ParallelStreamProcessor<String, String> setupParallelConsumer(MockConsumer<String, String> mockConsumer, final String topic) {
7575
ParallelConsumerOptions options = ParallelConsumerOptions.<String, String>builder()
76-
.ordering(KEY) // <2>
77-
.maxConcurrency(1000) // <3>
78-
.consumer(mockConsumer)
79-
.build();
76+
.ordering(KEY) // <2>
77+
.maxConcurrency(1000) // <3>
78+
.consumer(mockConsumer)
79+
.build();
8080

8181
ParallelStreamProcessor<String, String> parallelConsumer = ParallelStreamProcessor.createEosStreamProcessor(options);
8282
parallelConsumer.subscribe(Collections.singletonList(topic));

0 commit comments

Comments
 (0)