From 4e3f5a0af2b3ec941ca7199686e1fca73b1c36dc Mon Sep 17 00:00:00 2001 From: Dave Troiano Date: Wed, 5 Mar 2025 14:32:27 -0500 Subject: [PATCH 1/2] upgrade to AK 4.0 / CP 8.0 dependencies --- aggregating-average/kstreams/build.gradle | 6 ++--- aggregating-count/kstreams/build.gradle | 6 ++--- aggregating-minmax/kstreams/build.gradle | 6 ++--- aggregating-sum/kstreams/build.gradle | 6 ++--- build.gradle | 4 ++++ .../kafka/build.gradle | 2 +- cogrouping-streams/kstreams/build.gradle | 6 ++--- common/build.gradle | 2 +- .../kafka/build.gradle | 4 ++-- .../ParallelConsumerApplicationTest.java | 22 +++++++++---------- .../kstreams/build.gradle | 6 ++--- deduplication-windowed/kstreams/build.gradle | 6 ++--- dynamic-output-topic/kstreams/build.gradle | 6 ++--- error-handling/kstreams/build.gradle | 6 ++--- filtering/kstreams/build.gradle | 6 ++--- fk-joins/kstreams/build.gradle | 6 ++--- joining-stream-stream/kstreams/build.gradle | 6 ++--- joining-stream-table/kstreams/build.gradle | 6 ++--- joining-table-table/kstreams/build.gradle | 6 ++--- kafka-consumer-application/kafka/build.gradle | 6 ++++- .../KafkaConsumerApplicationTest.java | 16 +++++++++----- kafka-native-testcontainers/kafka/README.md | 10 ++++----- .../kafka/build.gradle | 8 +++++-- .../developer/KafkaPrimalityRouterTest.java | 2 +- kafka-producer-application/kafka/build.gradle | 2 +- .../developer/KafkaProducerApplication.java | 9 ++++++-- .../KafkaProducerApplicationTest.java | 2 +- .../kstreams/build.gradle | 6 ++--- merging/kstreams/build.gradle | 6 ++--- multiple-event-types-avro/kafka/build.gradle | 8 +++++-- .../MultiEventAvroProduceConsumeAppTest.java | 6 ++--- .../kafka/build.gradle | 8 +++++-- ...ltiEventProtobufProduceConsumeAppTest.java | 5 ++--- .../kstreams/build.gradle | 6 ++--- reordering-streams/kstreams/build.gradle | 6 ++--- .../kstreams/build.gradle | 6 ++--- schedule-ktable-ttl/kstreams/build.gradle | 6 ++--- serialization/kstreams/build.gradle | 20 ++++++----------- session-windows/kstreams/build.gradle | 6 ++--- sliding-windows/kstreams/build.gradle | 6 ++--- splitting/kstreams/build.gradle | 6 ++--- streams-to-table/kstreams/build.gradle | 6 ++--- transforming/kstreams/build.gradle | 6 ++--- tumbling-windows/kstreams/build.gradle | 6 ++--- versioned-ktables/kstreams/build.gradle | 6 ++--- window-final-result/kstreams/build.gradle | 6 ++--- 46 files changed, 162 insertions(+), 142 deletions(-) diff --git a/aggregating-average/kstreams/build.gradle b/aggregating-average/kstreams/build.gradle index a7f65ff3..d4189f66 100644 --- a/aggregating-average/kstreams/build.gradle +++ b/aggregating-average/kstreams/build.gradle @@ -28,16 +28,16 @@ repositories { dependencies { implementation project(':common') implementation "org.slf4j:slf4j-simple:2.0.7" - implementation 'org.apache.kafka:kafka-streams:3.6.0' + implementation 'org.apache.kafka:kafka-streams:4.0.0' implementation('org.apache.kafka:kafka-clients') { version { - strictly '3.6.0' + strictly '4.0.0' } } implementation "io.confluent:kafka-streams-avro-serde:7.5.1" implementation "com.typesafe:config:1.4.2" - testImplementation "org.apache.kafka:kafka-streams-test-utils:3.6.0" + testImplementation "org.apache.kafka:kafka-streams-test-utils:4.0.0" testImplementation 'org.junit.jupiter:junit-jupiter-api:5.9.2' testImplementation 'org.hamcrest:hamcrest:2.2' testRuntimeOnly 'org.junit.platform:junit-platform-launcher' diff --git a/aggregating-count/kstreams/build.gradle b/aggregating-count/kstreams/build.gradle index 6edb1b72..da4c21cd 100644 --- a/aggregating-count/kstreams/build.gradle +++ b/aggregating-count/kstreams/build.gradle @@ -27,16 +27,16 @@ repositories { dependencies { implementation project(':common') implementation "org.slf4j:slf4j-simple:2.0.7" - implementation 'org.apache.kafka:kafka-streams:3.6.0' + implementation 'org.apache.kafka:kafka-streams:4.0.0' implementation('org.apache.kafka:kafka-clients') { version { - strictly '3.6.0' + strictly '4.0.0' } } implementation "io.confluent:kafka-streams-avro-serde:7.5.1" implementation "com.typesafe:config:1.4.2" - testImplementation "org.apache.kafka:kafka-streams-test-utils:3.6.0" + testImplementation "org.apache.kafka:kafka-streams-test-utils:4.0.0" testImplementation 'org.junit.jupiter:junit-jupiter-api:5.9.2' testImplementation 'org.hamcrest:hamcrest:2.2' testRuntimeOnly 'org.junit.platform:junit-platform-launcher' diff --git a/aggregating-minmax/kstreams/build.gradle b/aggregating-minmax/kstreams/build.gradle index 262307bf..d6f7041e 100644 --- a/aggregating-minmax/kstreams/build.gradle +++ b/aggregating-minmax/kstreams/build.gradle @@ -35,16 +35,16 @@ repositories { dependencies { implementation project(':common') implementation "org.slf4j:slf4j-simple:2.0.7" - implementation 'org.apache.kafka:kafka-streams:3.6.0' + implementation 'org.apache.kafka:kafka-streams:4.0.0' implementation('org.apache.kafka:kafka-clients') { version { - strictly '3.6.0' + strictly '4.0.0' } } implementation "io.confluent:kafka-streams-avro-serde:7.5.1" implementation "com.typesafe:config:1.4.2" - testImplementation "org.apache.kafka:kafka-streams-test-utils:3.6.0" + testImplementation "org.apache.kafka:kafka-streams-test-utils:4.0.0" testImplementation 'org.junit.jupiter:junit-jupiter-api:5.9.2' testImplementation 'org.hamcrest:hamcrest:2.2' testRuntimeOnly 'org.junit.platform:junit-platform-launcher' diff --git a/aggregating-sum/kstreams/build.gradle b/aggregating-sum/kstreams/build.gradle index 1cbd8e21..6677297e 100644 --- a/aggregating-sum/kstreams/build.gradle +++ b/aggregating-sum/kstreams/build.gradle @@ -35,16 +35,16 @@ repositories { dependencies { implementation project(':common') implementation "org.slf4j:slf4j-simple:2.0.7" - implementation 'org.apache.kafka:kafka-streams:3.6.0' + implementation 'org.apache.kafka:kafka-streams:4.0.0' implementation('org.apache.kafka:kafka-clients') { version { - strictly '3.6.0' + strictly '4.0.0' } } implementation "io.confluent:kafka-streams-avro-serde:7.5.1" implementation "com.typesafe:config:1.4.2" - testImplementation "org.apache.kafka:kafka-streams-test-utils:3.6.0" + testImplementation "org.apache.kafka:kafka-streams-test-utils:4.0.0" testImplementation 'org.junit.jupiter:junit-jupiter-api:5.9.2' testImplementation 'org.hamcrest:hamcrest:2.2' testRuntimeOnly 'org.junit.platform:junit-platform-launcher' diff --git a/build.gradle b/build.gradle index 34da10be..570a6084 100644 --- a/build.gradle +++ b/build.gradle @@ -11,6 +11,10 @@ allprojects { repositories { mavenCentral() + maven { + url = uri("https://repository.apache.org/content/groups/staging/") + } + maven { url 'https://packages.confluent.io/maven/' } } } diff --git a/client-telemetry-reporter-plugin/kafka/build.gradle b/client-telemetry-reporter-plugin/kafka/build.gradle index 2cab2527..3492aafb 100644 --- a/client-telemetry-reporter-plugin/kafka/build.gradle +++ b/client-telemetry-reporter-plugin/kafka/build.gradle @@ -29,7 +29,7 @@ dependencies { implementation "io.grpc:grpc-stub:1.66.0" implementation('org.apache.kafka:kafka-clients') { version { - strictly '3.8.0' + strictly '4.0.0' } } } diff --git a/cogrouping-streams/kstreams/build.gradle b/cogrouping-streams/kstreams/build.gradle index 8e629727..64cea6b5 100644 --- a/cogrouping-streams/kstreams/build.gradle +++ b/cogrouping-streams/kstreams/build.gradle @@ -36,16 +36,16 @@ repositories { dependencies { implementation project(':common') implementation "org.slf4j:slf4j-simple:2.0.7" - implementation 'org.apache.kafka:kafka-streams:3.6.0' + implementation 'org.apache.kafka:kafka-streams:4.0.0' implementation('org.apache.kafka:kafka-clients') { version { - strictly '3.6.0' + strictly '4.0.0' } } implementation "io.confluent:kafka-streams-avro-serde:7.5.1" implementation "com.typesafe:config:1.4.2" - testImplementation "org.apache.kafka:kafka-streams-test-utils:3.6.0" + testImplementation "org.apache.kafka:kafka-streams-test-utils:4.0.0" testImplementation 'org.junit.jupiter:junit-jupiter-api:5.9.2' testImplementation 'org.hamcrest:hamcrest:2.2' testRuntimeOnly 'org.junit.platform:junit-platform-launcher' diff --git a/common/build.gradle b/common/build.gradle index 463987ee..70514d39 100644 --- a/common/build.gradle +++ b/common/build.gradle @@ -39,7 +39,7 @@ dependencies { implementation 'org.slf4j:slf4j-simple:2.0.7' implementation('org.apache.kafka:kafka-clients') { version { - strictly '3.7.0' + strictly '4.0.0' } } implementation 'io.confluent:kafka-streams-avro-serde:7.5.1' diff --git a/confluent-parallel-consumer-application/kafka/build.gradle b/confluent-parallel-consumer-application/kafka/build.gradle index 2741d61c..38e60c89 100644 --- a/confluent-parallel-consumer-application/kafka/build.gradle +++ b/confluent-parallel-consumer-application/kafka/build.gradle @@ -31,7 +31,7 @@ repositories { dependencies { implementation project(':common') implementation "org.slf4j:slf4j-simple:2.0.7" - implementation "io.confluent.parallelconsumer:parallel-consumer-core:0.5.2.4" + implementation "io.confluent.parallelconsumer:parallel-consumer-core:0.5.3.2" implementation "org.apache.commons:commons-lang3:3.12.0" implementation "me.tongfei:progressbar:0.9.3" implementation 'org.awaitility:awaitility:4.2.0' @@ -41,7 +41,7 @@ dependencies { testImplementation 'org.junit.jupiter:junit-jupiter-api:5.9.2' testImplementation 'org.hamcrest:hamcrest:2.2' testImplementation 'org.awaitility:awaitility:4.2.0' - testImplementation "io.confluent.parallelconsumer:parallel-consumer-core:0.5.2.4:tests" // for LongPollingMockConsumer + testImplementation "io.confluent.parallelconsumer:parallel-consumer-core:0.5.3.2:tests" // for LongPollingMockConsumer testRuntimeOnly 'org.junit.platform:junit-platform-launcher' testRuntimeOnly 'org.junit.jupiter:junit-jupiter-engine:5.9.2' } diff --git a/confluent-parallel-consumer-application/kafka/src/test/java/io/confluent/developer/ParallelConsumerApplicationTest.java b/confluent-parallel-consumer-application/kafka/src/test/java/io/confluent/developer/ParallelConsumerApplicationTest.java index 6266f96f..1ca8c947 100644 --- a/confluent-parallel-consumer-application/kafka/src/test/java/io/confluent/developer/ParallelConsumerApplicationTest.java +++ b/confluent-parallel-consumer-application/kafka/src/test/java/io/confluent/developer/ParallelConsumerApplicationTest.java @@ -61,22 +61,22 @@ public void consumerTest() throws Exception { expectedRecords.add("baz"); final Set actualRecords = new HashSet<>(); Awaitility.await() - .atMost(5, SECONDS) - .pollInterval(Duration.ofSeconds(1)) - .until(() -> { - actualRecords.clear(); - actualRecords.addAll(Files.readAllLines(tempFilePath)); - return actualRecords.size() == 3; - }); + .atMost(5, SECONDS) + .pollInterval(Duration.ofSeconds(1)) + .until(() -> { + actualRecords.clear(); + actualRecords.addAll(Files.readAllLines(tempFilePath)); + return actualRecords.size() == 3; + }); assertEquals(actualRecords, expectedRecords); } private ParallelStreamProcessor setupParallelConsumer(MockConsumer mockConsumer, final String topic) { ParallelConsumerOptions options = ParallelConsumerOptions.builder() - .ordering(KEY) // <2> - .maxConcurrency(1000) // <3> - .consumer(mockConsumer) - .build(); + .ordering(KEY) // <2> + .maxConcurrency(1000) // <3> + .consumer(mockConsumer) + .build(); ParallelStreamProcessor parallelConsumer = ParallelStreamProcessor.createEosStreamProcessor(options); parallelConsumer.subscribe(Collections.singletonList(topic)); diff --git a/creating-first-apache-kafka-streams-application/kstreams/build.gradle b/creating-first-apache-kafka-streams-application/kstreams/build.gradle index 379dc65c..e2b715a8 100644 --- a/creating-first-apache-kafka-streams-application/kstreams/build.gradle +++ b/creating-first-apache-kafka-streams-application/kstreams/build.gradle @@ -36,15 +36,15 @@ repositories { dependencies { implementation project(':common') implementation "org.slf4j:slf4j-simple:2.0.7" - implementation 'org.apache.kafka:kafka-streams:3.6.0' + implementation 'org.apache.kafka:kafka-streams:4.0.0' implementation('org.apache.kafka:kafka-clients') { version { - strictly '3.6.0' + strictly '4.0.0' } } implementation "io.confluent:kafka-streams-avro-serde:7.5.1" - testImplementation "org.apache.kafka:kafka-streams-test-utils:3.6.0" + testImplementation "org.apache.kafka:kafka-streams-test-utils:4.0.0" testImplementation 'org.junit.jupiter:junit-jupiter-api:5.9.2' testImplementation 'org.hamcrest:hamcrest:2.2' testRuntimeOnly 'org.junit.platform:junit-platform-launcher' diff --git a/deduplication-windowed/kstreams/build.gradle b/deduplication-windowed/kstreams/build.gradle index e17d0edf..a4640141 100644 --- a/deduplication-windowed/kstreams/build.gradle +++ b/deduplication-windowed/kstreams/build.gradle @@ -27,14 +27,14 @@ repositories { dependencies { implementation project(':common') implementation "org.slf4j:slf4j-simple:2.0.7" - implementation 'org.apache.kafka:kafka-streams:3.6.0' + implementation 'org.apache.kafka:kafka-streams:4.0.0' implementation('org.apache.kafka:kafka-clients') { version { - strictly '3.6.0' + strictly '4.0.0' } } - testImplementation "org.apache.kafka:kafka-streams-test-utils:3.6.0" + testImplementation "org.apache.kafka:kafka-streams-test-utils:4.0.0" testImplementation 'org.junit.jupiter:junit-jupiter-api:5.9.2' testImplementation 'org.hamcrest:hamcrest:2.2' testRuntimeOnly 'org.junit.platform:junit-platform-launcher' diff --git a/dynamic-output-topic/kstreams/build.gradle b/dynamic-output-topic/kstreams/build.gradle index f07bfa0a..6f23f3b6 100644 --- a/dynamic-output-topic/kstreams/build.gradle +++ b/dynamic-output-topic/kstreams/build.gradle @@ -27,16 +27,16 @@ repositories { dependencies { implementation project(':common') implementation "org.slf4j:slf4j-simple:2.0.7" - implementation 'org.apache.kafka:kafka-streams:3.6.0' + implementation 'org.apache.kafka:kafka-streams:4.0.0' implementation('org.apache.kafka:kafka-clients') { version { - strictly '3.6.0' + strictly '4.0.0' } } implementation "io.confluent:kafka-streams-avro-serde:7.5.1" implementation "com.typesafe:config:1.4.2" - testImplementation "org.apache.kafka:kafka-streams-test-utils:3.6.0" + testImplementation "org.apache.kafka:kafka-streams-test-utils:4.0.0" testImplementation 'org.junit.jupiter:junit-jupiter-api:5.9.2' testImplementation 'org.hamcrest:hamcrest:2.2' testRuntimeOnly 'org.junit.platform:junit-platform-launcher' diff --git a/error-handling/kstreams/build.gradle b/error-handling/kstreams/build.gradle index 371377e8..4356db62 100644 --- a/error-handling/kstreams/build.gradle +++ b/error-handling/kstreams/build.gradle @@ -36,16 +36,16 @@ repositories { dependencies { implementation project(':common') implementation "org.slf4j:slf4j-simple:2.0.7" - implementation 'org.apache.kafka:kafka-streams:3.6.0' + implementation 'org.apache.kafka:kafka-streams:4.0.0' implementation('org.apache.kafka:kafka-clients') { version { - strictly '3.6.0' + strictly '4.0.0' } } implementation "io.confluent:kafka-streams-avro-serde:7.5.1" implementation "com.typesafe:config:1.4.2" - testImplementation "org.apache.kafka:kafka-streams-test-utils:3.6.0" + testImplementation "org.apache.kafka:kafka-streams-test-utils:4.0.0" testImplementation 'org.junit.jupiter:junit-jupiter-api:5.9.2' testImplementation 'org.hamcrest:hamcrest:2.2' testRuntimeOnly 'org.junit.platform:junit-platform-launcher' diff --git a/filtering/kstreams/build.gradle b/filtering/kstreams/build.gradle index 44a29c5f..76c58e7b 100644 --- a/filtering/kstreams/build.gradle +++ b/filtering/kstreams/build.gradle @@ -27,13 +27,13 @@ repositories { dependencies { implementation project(':common') implementation "org.slf4j:slf4j-simple:2.0.7" - implementation 'org.apache.kafka:kafka-streams:3.6.0' + implementation 'org.apache.kafka:kafka-streams:4.0.0' implementation ('org.apache.kafka:kafka-clients') { version { - strictly '3.6.0' + strictly '4.0.0' } } - testImplementation "org.apache.kafka:kafka-streams-test-utils:3.6.0" + testImplementation "org.apache.kafka:kafka-streams-test-utils:4.0.0" testImplementation 'org.junit.jupiter:junit-jupiter-api:5.9.2' testImplementation 'org.hamcrest:hamcrest:2.2' testRuntimeOnly 'org.junit.platform:junit-platform-launcher' diff --git a/fk-joins/kstreams/build.gradle b/fk-joins/kstreams/build.gradle index 2b959d56..2963de0b 100644 --- a/fk-joins/kstreams/build.gradle +++ b/fk-joins/kstreams/build.gradle @@ -32,14 +32,14 @@ repositories { dependencies { implementation project(':common') implementation "org.slf4j:slf4j-simple:2.0.7" - implementation 'org.apache.kafka:kafka-streams:3.6.0' + implementation 'org.apache.kafka:kafka-streams:4.0.0' implementation('org.apache.kafka:kafka-clients') { version { - strictly '3.6.0' + strictly '4.0.0' } } - testImplementation "org.apache.kafka:kafka-streams-test-utils:3.6.0" + testImplementation "org.apache.kafka:kafka-streams-test-utils:4.0.0" testImplementation 'org.junit.jupiter:junit-jupiter-api:5.9.2' testImplementation 'org.hamcrest:hamcrest:2.2' testRuntimeOnly 'org.junit.platform:junit-platform-launcher' diff --git a/joining-stream-stream/kstreams/build.gradle b/joining-stream-stream/kstreams/build.gradle index 7f2247a3..5106d259 100644 --- a/joining-stream-stream/kstreams/build.gradle +++ b/joining-stream-stream/kstreams/build.gradle @@ -27,14 +27,14 @@ repositories { dependencies { implementation project(':common') implementation "org.slf4j:slf4j-simple:2.0.7" - implementation 'org.apache.kafka:kafka-streams:3.7.0' + implementation 'org.apache.kafka:kafka-streams:4.0.0' implementation('org.apache.kafka:kafka-clients') { version { - strictly '3.7.0' + strictly '4.0.0' } } - testImplementation "org.apache.kafka:kafka-streams-test-utils:3.7.0" + testImplementation "org.apache.kafka:kafka-streams-test-utils:4.0.0" testImplementation 'org.junit.jupiter:junit-jupiter-api:5.9.2' testImplementation 'org.hamcrest:hamcrest:2.2' testRuntimeOnly 'org.junit.platform:junit-platform-launcher' diff --git a/joining-stream-table/kstreams/build.gradle b/joining-stream-table/kstreams/build.gradle index 78b6260a..fe523447 100644 --- a/joining-stream-table/kstreams/build.gradle +++ b/joining-stream-table/kstreams/build.gradle @@ -27,14 +27,14 @@ repositories { dependencies { implementation project(':common') implementation "org.slf4j:slf4j-simple:2.0.7" - implementation 'org.apache.kafka:kafka-streams:3.6.0' + implementation 'org.apache.kafka:kafka-streams:4.0.0' implementation('org.apache.kafka:kafka-clients') { version { - strictly '3.6.0' + strictly '4.0.0' } } - testImplementation "org.apache.kafka:kafka-streams-test-utils:3.6.0" + testImplementation "org.apache.kafka:kafka-streams-test-utils:4.0.0" testImplementation 'org.junit.jupiter:junit-jupiter-api:5.9.2' testImplementation 'org.hamcrest:hamcrest:2.2' testRuntimeOnly 'org.junit.platform:junit-platform-launcher' diff --git a/joining-table-table/kstreams/build.gradle b/joining-table-table/kstreams/build.gradle index d95b1cc9..09d921f2 100644 --- a/joining-table-table/kstreams/build.gradle +++ b/joining-table-table/kstreams/build.gradle @@ -27,14 +27,14 @@ repositories { dependencies { implementation project(':common') implementation "org.slf4j:slf4j-simple:2.0.7" - implementation 'org.apache.kafka:kafka-streams:3.7.1' + implementation 'org.apache.kafka:kafka-streams:4.0.0' implementation('org.apache.kafka:kafka-clients') { version { - strictly '3.7.1' + strictly '4.0.0' } } - testImplementation "org.apache.kafka:kafka-streams-test-utils:3.7.1" + testImplementation "org.apache.kafka:kafka-streams-test-utils:4.0.0" testImplementation 'org.junit.jupiter:junit-jupiter-api:5.9.2' testImplementation 'org.hamcrest:hamcrest:2.2' testRuntimeOnly 'org.junit.platform:junit-platform-launcher' diff --git a/kafka-consumer-application/kafka/build.gradle b/kafka-consumer-application/kafka/build.gradle index 96ddcdab..5e22f180 100644 --- a/kafka-consumer-application/kafka/build.gradle +++ b/kafka-consumer-application/kafka/build.gradle @@ -32,7 +32,11 @@ repositories { dependencies { implementation 'org.slf4j:slf4j-simple:2.0.7' - implementation 'org.apache.kafka:kafka-clients:3.6.0' + implementation('org.apache.kafka:kafka-clients') { + version { + strictly '4.0.0' + } + } testImplementation 'org.junit.jupiter:junit-jupiter-api:5.9.2' testRuntimeOnly 'org.junit.platform:junit-platform-launcher' testRuntimeOnly 'org.junit.jupiter:junit-jupiter-engine:5.9.2' diff --git a/kafka-consumer-application/kafka/src/test/java/io/confluent/developer/KafkaConsumerApplicationTest.java b/kafka-consumer-application/kafka/src/test/java/io/confluent/developer/KafkaConsumerApplicationTest.java index 90a150c7..b0359e3b 100644 --- a/kafka-consumer-application/kafka/src/test/java/io/confluent/developer/KafkaConsumerApplicationTest.java +++ b/kafka-consumer-application/kafka/src/test/java/io/confluent/developer/KafkaConsumerApplicationTest.java @@ -2,11 +2,15 @@ import org.apache.kafka.clients.consumer.ConsumerRecord; import org.apache.kafka.clients.consumer.MockConsumer; -import org.apache.kafka.clients.consumer.OffsetResetStrategy; import org.apache.kafka.common.TopicPartition; import org.junit.jupiter.api.Test; -import java.util.*; +import java.util.ArrayList; +import java.util.Arrays; +import java.util.Collections; +import java.util.HashMap; +import java.util.List; +import java.util.Map; import static org.junit.jupiter.api.Assertions.assertEquals; @@ -22,10 +26,10 @@ public void consumerTest() throws Exception { final String topic = "input-topic"; final TopicPartition topicPartition = new TopicPartition(topic, 0); - final MockConsumer mockConsumer = new MockConsumer<>(OffsetResetStrategy.EARLIEST); + final MockConsumer mockConsumer = new MockConsumer<>("earliest"); final KafkaConsumerApplication consumerApplication = new KafkaConsumerApplication(mockConsumer); - + mockConsumer.schedulePollTask(() -> addTopicPartitionsAssignmentAndAddConsumerRecords(topic, mockConsumer, topicPartition)); mockConsumer.schedulePollTask(consumerApplication::shutdown); @@ -36,8 +40,8 @@ public void consumerTest() throws Exception { } private void addTopicPartitionsAssignmentAndAddConsumerRecords(final String topic, - final MockConsumer mockConsumer, - final TopicPartition topicPartition) { + final MockConsumer mockConsumer, + final TopicPartition topicPartition) { final Map beginningOffsets = new HashMap<>(); beginningOffsets.put(topicPartition, 0L); diff --git a/kafka-native-testcontainers/kafka/README.md b/kafka-native-testcontainers/kafka/README.md index 2df27784..d4faaccc 100644 --- a/kafka-native-testcontainers/kafka/README.md +++ b/kafka-native-testcontainers/kafka/README.md @@ -11,7 +11,7 @@ In this tutorial, we will use the `apache/kafka-native` Docker Image released in Given these benefits, this image is well-suited for non-production development and testing scenarios that require an actual Kafka broker. [Testcontainers](https://java.testcontainers.org/modules/kafka/) supports this image as of version `1.20.1` of `org.testcontainers`'s `kafka` module. -Testing in this way is as easy as declaring the [Testcontainers Kafka dependency](https://mvnrepository.com/artifact/org.testcontainers/kafka/1.20.1) in your dependency manager and then writing a test like this: +Testing in this way is as easy as declaring the [Testcontainers Kafka dependency](https://mvnrepository.com/artifact/org.testcontainers/kafka/1.20.5) in your dependency manager and then writing a test like this: ```java try (KafkaContainer kafka = new KafkaContainer(DockerImageName.parse("apache/kafka-native:"))) { @@ -101,20 +101,20 @@ To run the test, use the provided Gradle Wrapper: You can compare test runtimes between the `apache/kafka-native` and `apache/kafka` images by replacing this line in the test: ```java - try (KafkaContainer kafka = new KafkaContainer(DockerImageName.parse("apache/kafka-native:3.8.0"))) { + try (KafkaContainer kafka = new KafkaContainer(DockerImageName.parse("apache/kafka-native:4.0.0"))) { ``` with this: ```java - try (KafkaContainer kafka = new KafkaContainer(DockerImageName.parse("apache/kafka:3.8.0"))) { + try (KafkaContainer kafka = new KafkaContainer(DockerImageName.parse("apache/kafka:4.0.0"))) { ``` Now you can compare test performance both with the images downloaded and without. First, make sure that the images aren't available locally: ```noformat -docker rmi apache/kafka-native:3.8.0 -docker rmi apache/kafka:3.8.0 +docker rmi apache/kafka-native:4.0.0 +docker rmi apache/kafka:4.0.0 ``` Next, run the test twice, once using the `apache/kafka` image, and again using the `apache/kafka-native` image. Test diff --git a/kafka-native-testcontainers/kafka/build.gradle b/kafka-native-testcontainers/kafka/build.gradle index 0256faf0..7ff9170f 100644 --- a/kafka-native-testcontainers/kafka/build.gradle +++ b/kafka-native-testcontainers/kafka/build.gradle @@ -32,10 +32,14 @@ repositories { dependencies { implementation 'org.slf4j:slf4j-simple:2.0.7' - implementation 'org.apache.kafka:kafka-clients:3.8.0' + implementation('org.apache.kafka:kafka-clients') { + version { + strictly '4.0.0' + } + } implementation 'org.apache.commons:commons-math3:3.6.1' testImplementation 'org.junit.jupiter:junit-jupiter-api:5.9.2' - testImplementation 'org.testcontainers:kafka:1.20.1' + testImplementation 'org.testcontainers:kafka:1.20.5' testRuntimeOnly 'org.junit.platform:junit-platform-launcher' testRuntimeOnly 'org.junit.jupiter:junit-jupiter-engine:5.9.2' } diff --git a/kafka-native-testcontainers/kafka/src/test/java/io/confluent/developer/KafkaPrimalityRouterTest.java b/kafka-native-testcontainers/kafka/src/test/java/io/confluent/developer/KafkaPrimalityRouterTest.java index daa1beed..f3e83541 100644 --- a/kafka-native-testcontainers/kafka/src/test/java/io/confluent/developer/KafkaPrimalityRouterTest.java +++ b/kafka-native-testcontainers/kafka/src/test/java/io/confluent/developer/KafkaPrimalityRouterTest.java @@ -31,7 +31,7 @@ public class KafkaPrimalityRouterTest { @Test public void testPrimalityRouter() { - try (KafkaContainer kafka = new KafkaContainer(DockerImageName.parse("apache/kafka-native:3.8.0"))) { + try (KafkaContainer kafka = new KafkaContainer(DockerImageName.parse("apache/kafka-native:4.0.0-rc1"))) { kafka.start(); // kick off application main method in a thread diff --git a/kafka-producer-application/kafka/build.gradle b/kafka-producer-application/kafka/build.gradle index 4f7e6a8e..612c5974 100644 --- a/kafka-producer-application/kafka/build.gradle +++ b/kafka-producer-application/kafka/build.gradle @@ -32,7 +32,7 @@ repositories { dependencies { implementation project(":common") implementation "org.slf4j:slf4j-simple:2.0.7" - implementation "org.apache.kafka:kafka-clients:3.6.0" + implementation "org.apache.kafka:kafka-clients:4.0.0" testImplementation 'com.google.guava:guava:31.1-jre' testImplementation 'org.junit.jupiter:junit-jupiter-api:5.9.2' testRuntimeOnly 'org.junit.platform:junit-platform-launcher' diff --git a/kafka-producer-application/kafka/src/main/java/io/confluent/developer/KafkaProducerApplication.java b/kafka-producer-application/kafka/src/main/java/io/confluent/developer/KafkaProducerApplication.java index f2c46cca..fdc224f3 100644 --- a/kafka-producer-application/kafka/src/main/java/io/confluent/developer/KafkaProducerApplication.java +++ b/kafka-producer-application/kafka/src/main/java/io/confluent/developer/KafkaProducerApplication.java @@ -1,7 +1,12 @@ package io.confluent.developer; -import org.apache.kafka.clients.producer.*; +import org.apache.kafka.clients.producer.Callback; +import org.apache.kafka.clients.producer.KafkaProducer; +import org.apache.kafka.clients.producer.Producer; +import org.apache.kafka.clients.producer.ProducerConfig; +import org.apache.kafka.clients.producer.ProducerRecord; +import org.apache.kafka.clients.producer.RecordMetadata; import org.apache.kafka.common.serialization.StringSerializer; import java.io.IOException; @@ -44,7 +49,7 @@ public void printMetadata(final Collection> metadata, }); } - public static void main(String[] args) throws Exception { + public static void main(String[] args) { if (args.length < 2) { throw new IllegalArgumentException( "Usage: this program takes 2 arguments: \n" + diff --git a/kafka-producer-application/kafka/src/test/java/io/confluent/developer/KafkaProducerApplicationTest.java b/kafka-producer-application/kafka/src/test/java/io/confluent/developer/KafkaProducerApplicationTest.java index 69c45a75..dc10f981 100644 --- a/kafka-producer-application/kafka/src/test/java/io/confluent/developer/KafkaProducerApplicationTest.java +++ b/kafka-producer-application/kafka/src/test/java/io/confluent/developer/KafkaProducerApplicationTest.java @@ -34,7 +34,7 @@ public static void setup() { @BeforeEach public void setupEach() { final StringSerializer stringSerializer = new StringSerializer(); - mockProducer = new MockProducer<>(true, stringSerializer, stringSerializer); + mockProducer = new MockProducer<>(true, null, stringSerializer, stringSerializer); } @Test diff --git a/kafka-streams-schedule-operations/kstreams/build.gradle b/kafka-streams-schedule-operations/kstreams/build.gradle index 4403fc94..11a7a401 100644 --- a/kafka-streams-schedule-operations/kstreams/build.gradle +++ b/kafka-streams-schedule-operations/kstreams/build.gradle @@ -30,14 +30,14 @@ repositories { dependencies { implementation project(':common') implementation "org.slf4j:slf4j-simple:2.0.7" - implementation 'org.apache.kafka:kafka-streams:3.6.0' + implementation 'org.apache.kafka:kafka-streams:4.0.0' implementation('org.apache.kafka:kafka-clients') { version { - strictly '3.6.0' + strictly '4.0.0' } } - testImplementation "org.apache.kafka:kafka-streams-test-utils:3.6.0" + testImplementation "org.apache.kafka:kafka-streams-test-utils:4.0.0" testImplementation 'org.junit.jupiter:junit-jupiter-api:5.9.2' testImplementation 'org.hamcrest:hamcrest:2.2' testRuntimeOnly 'org.junit.platform:junit-platform-launcher' diff --git a/merging/kstreams/build.gradle b/merging/kstreams/build.gradle index fb43f147..2c319d4a 100644 --- a/merging/kstreams/build.gradle +++ b/merging/kstreams/build.gradle @@ -30,14 +30,14 @@ repositories { dependencies { implementation project(':common') implementation "org.slf4j:slf4j-simple:2.0.7" - implementation 'org.apache.kafka:kafka-streams:3.6.0' + implementation 'org.apache.kafka:kafka-streams:4.0.0' implementation('org.apache.kafka:kafka-clients') { version { - strictly '3.6.0' + strictly '4.0.0' } } - testImplementation "org.apache.kafka:kafka-streams-test-utils:3.6.0" + testImplementation "org.apache.kafka:kafka-streams-test-utils:4.0.0" testImplementation 'org.junit.jupiter:junit-jupiter-api:5.9.2' testImplementation 'org.hamcrest:hamcrest:2.2' testRuntimeOnly 'org.junit.platform:junit-platform-launcher' diff --git a/multiple-event-types-avro/kafka/build.gradle b/multiple-event-types-avro/kafka/build.gradle index 0a10399e..3931b1cb 100644 --- a/multiple-event-types-avro/kafka/build.gradle +++ b/multiple-event-types-avro/kafka/build.gradle @@ -41,8 +41,12 @@ apply plugin: "com.github.johnrengelman.shadow" dependencies { implementation "org.slf4j:slf4j-simple:2.0.7" - implementation "org.apache.kafka:kafka-clients:3.6.0" - implementation 'org.apache.kafka:kafka-streams:3.6.0' + implementation('org.apache.kafka:kafka-clients') { + version { + strictly '4.0.0' + } + } + implementation 'org.apache.kafka:kafka-streams:4.0.0' implementation 'org.apache.avro:avro:1.11.1' implementation "io.confluent:kafka-avro-serializer:7.5.1" testImplementation 'com.google.guava:guava:31.1-jre' diff --git a/multiple-event-types-avro/kafka/src/test/java/io/confluent/developer/MultiEventAvroProduceConsumeAppTest.java b/multiple-event-types-avro/kafka/src/test/java/io/confluent/developer/MultiEventAvroProduceConsumeAppTest.java index b9e1013e..d03cbf91 100644 --- a/multiple-event-types-avro/kafka/src/test/java/io/confluent/developer/MultiEventAvroProduceConsumeAppTest.java +++ b/multiple-event-types-avro/kafka/src/test/java/io/confluent/developer/MultiEventAvroProduceConsumeAppTest.java @@ -3,7 +3,6 @@ import org.apache.avro.specific.SpecificRecordBase; import org.apache.kafka.clients.consumer.ConsumerRecord; import org.apache.kafka.clients.consumer.MockConsumer; -import org.apache.kafka.clients.consumer.OffsetResetStrategy; import org.apache.kafka.clients.producer.MockProducer; import org.apache.kafka.clients.producer.ProducerRecord; import org.apache.kafka.common.TopicPartition; @@ -19,7 +18,6 @@ import java.util.HashMap; import java.util.List; import java.util.Map; -import java.util.Properties; import java.util.concurrent.atomic.AtomicInteger; import java.util.function.Function; import java.util.stream.Collectors; @@ -48,7 +46,7 @@ public void testProduceAvroMultipleEvents() { commonConfigs.put("schema.registry.url", "mock://multi-event-produce-consume-test"); avroSerializer.configure(commonConfigs, false); MockProducer mockAvroProducer - = new MockProducer(true, stringSerializer, (Serializer) avroSerializer); + = new MockProducer(true, null, stringSerializer, (Serializer) avroSerializer); produceConsumeApp.produceAvroEvents(() -> mockAvroProducer, TOPIC, produceConsumeApp.avroEvents()); List> expectedKeyValues = produceConsumeApp.avroEvents().stream().map((e -> KeyValue.pair((String) e.get("customer_id"), e))).collect(Collectors.toList()); @@ -60,7 +58,7 @@ public void testProduceAvroMultipleEvents() { @Test public void testConsumeAvroEvents() { - MockConsumer mockConsumer = new MockConsumer<>(OffsetResetStrategy.EARLIEST); + MockConsumer mockConsumer = new MockConsumer<>("earliest"); List expectedAvroResults = Arrays.asList("Avro Pageview event -> http://acme/traps", "Avro Pageview event -> http://acme/bombs", "Avro Pageview event -> http://acme/bait", "Avro Purchase event -> road-runner-bait"); List actualAvroResults = new ArrayList<>(); mockConsumer.schedulePollTask(() -> { diff --git a/multiple-event-types-protobuf/kafka/build.gradle b/multiple-event-types-protobuf/kafka/build.gradle index 0b101009..ecbb5400 100644 --- a/multiple-event-types-protobuf/kafka/build.gradle +++ b/multiple-event-types-protobuf/kafka/build.gradle @@ -41,8 +41,12 @@ apply plugin: "com.github.johnrengelman.shadow" dependencies { implementation "org.slf4j:slf4j-simple:2.0.7" - implementation "org.apache.kafka:kafka-clients:3.6.0" - implementation 'org.apache.kafka:kafka-streams:3.6.0' + implementation('org.apache.kafka:kafka-clients') { + version { + strictly '4.0.0' + } + } + implementation 'org.apache.kafka:kafka-streams:4.0.0' implementation 'com.google.protobuf:protobuf-java:3.22.2' implementation "io.confluent:kafka-protobuf-serializer:7.5.1" implementation "io.confluent:kafka-protobuf-provider:7.5.1" diff --git a/multiple-event-types-protobuf/kafka/src/test/java/io/confluent/developer/MultiEventProtobufProduceConsumeAppTest.java b/multiple-event-types-protobuf/kafka/src/test/java/io/confluent/developer/MultiEventProtobufProduceConsumeAppTest.java index f74941ee..90fe3d9a 100644 --- a/multiple-event-types-protobuf/kafka/src/test/java/io/confluent/developer/MultiEventProtobufProduceConsumeAppTest.java +++ b/multiple-event-types-protobuf/kafka/src/test/java/io/confluent/developer/MultiEventProtobufProduceConsumeAppTest.java @@ -2,7 +2,6 @@ import org.apache.kafka.clients.consumer.ConsumerRecord; import org.apache.kafka.clients.consumer.MockConsumer; -import org.apache.kafka.clients.consumer.OffsetResetStrategy; import org.apache.kafka.clients.producer.MockProducer; import org.apache.kafka.clients.producer.ProducerRecord; import org.apache.kafka.common.TopicPartition; @@ -46,7 +45,7 @@ public void testProduceProtobufMultipleEvents() { commonConfigs.put("schema.registry.url", "mock://multi-event-produce-consume-test"); protobufSerializer.configure(commonConfigs, false); MockProducer mockProtoProducer - = new MockProducer<>(true, stringSerializer, protobufSerializer); + = new MockProducer<>(true, null, stringSerializer, protobufSerializer); List events = produceConsumeApp.protobufEvents(); produceConsumeApp.produceProtobufEvents(() -> mockProtoProducer, TOPIC, events); List> expectedKeyValues = @@ -59,7 +58,7 @@ public void testProduceProtobufMultipleEvents() { @Test public void testConsumeProtobufEvents() { - MockConsumer mockConsumer = new MockConsumer<>(OffsetResetStrategy.EARLIEST); + MockConsumer mockConsumer = new MockConsumer<>("earliest"); List expectedProtoResults = Arrays.asList("Protobuf Pageview event -> http://acme/traps", "Protobuf Pageview event -> http://acme/bombs", "Protobuf Pageview event -> http://acme/bait", "Protobuf Purchase event -> road-runner-bait"); List actualProtoResults = new ArrayList<>(); mockConsumer.schedulePollTask(()-> { diff --git a/naming-changelog-repartition-topics/kstreams/build.gradle b/naming-changelog-repartition-topics/kstreams/build.gradle index 07e55abb..fab54c4e 100644 --- a/naming-changelog-repartition-topics/kstreams/build.gradle +++ b/naming-changelog-repartition-topics/kstreams/build.gradle @@ -36,16 +36,16 @@ repositories { dependencies { implementation project(':common') implementation "org.slf4j:slf4j-simple:2.0.7" - implementation 'org.apache.kafka:kafka-streams:3.6.0' + implementation 'org.apache.kafka:kafka-streams:4.0.0' implementation('org.apache.kafka:kafka-clients') { version { - strictly '3.6.0' + strictly '4.0.0' } } implementation "io.confluent:kafka-streams-avro-serde:7.5.1" implementation "com.typesafe:config:1.4.2" - testImplementation "org.apache.kafka:kafka-streams-test-utils:3.6.0" + testImplementation "org.apache.kafka:kafka-streams-test-utils:4.0.0" testImplementation 'org.junit.jupiter:junit-jupiter-api:5.9.2' testImplementation 'org.hamcrest:hamcrest:2.2' testRuntimeOnly 'org.junit.platform:junit-platform-launcher' diff --git a/reordering-streams/kstreams/build.gradle b/reordering-streams/kstreams/build.gradle index 7365e076..c0bf8ca4 100644 --- a/reordering-streams/kstreams/build.gradle +++ b/reordering-streams/kstreams/build.gradle @@ -30,10 +30,10 @@ repositories { dependencies { implementation project(':common') implementation "org.slf4j:slf4j-simple:2.0.7" - implementation 'org.apache.kafka:kafka-streams:3.7.0' - implementation 'org.apache.kafka:kafka-clients:3.7.0' + implementation 'org.apache.kafka:kafka-streams:4.0.0' + implementation 'org.apache.kafka:kafka-clients:4.0.0' - testImplementation 'org.apache.kafka:kafka-streams-test-utils:3.7.0' + testImplementation 'org.apache.kafka:kafka-streams-test-utils:4.0.0' testImplementation 'org.junit.jupiter:junit-jupiter-api:5.9.2' testImplementation 'org.hamcrest:hamcrest:2.2' testRuntimeOnly 'org.junit.platform:junit-platform-launcher' diff --git a/schedule-ktable-ttl-aggregate/kstreams/build.gradle b/schedule-ktable-ttl-aggregate/kstreams/build.gradle index 54181eb4..0d663edb 100644 --- a/schedule-ktable-ttl-aggregate/kstreams/build.gradle +++ b/schedule-ktable-ttl-aggregate/kstreams/build.gradle @@ -28,15 +28,15 @@ dependencies { implementation project(':common') implementation "org.slf4j:slf4j-simple:2.0.7" implementation "io.confluent:common-utils:7.3.3" - implementation 'org.apache.kafka:kafka-streams:3.6.0' + implementation 'org.apache.kafka:kafka-streams:4.0.0' implementation('org.apache.kafka:kafka-clients') { version { - strictly '3.6.0' + strictly '4.0.0' } } implementation "com.typesafe:config:1.4.2" - testImplementation "org.apache.kafka:kafka-streams-test-utils:3.6.0" + testImplementation "org.apache.kafka:kafka-streams-test-utils:4.0.0" testImplementation 'org.junit.jupiter:junit-jupiter-api:5.9.2' testImplementation 'org.hamcrest:hamcrest:2.2' testRuntimeOnly 'org.junit.platform:junit-platform-launcher' diff --git a/schedule-ktable-ttl/kstreams/build.gradle b/schedule-ktable-ttl/kstreams/build.gradle index 0dafa8bf..c6b150d3 100644 --- a/schedule-ktable-ttl/kstreams/build.gradle +++ b/schedule-ktable-ttl/kstreams/build.gradle @@ -28,15 +28,15 @@ dependencies { implementation project(':common') implementation "org.slf4j:slf4j-simple:2.0.7" implementation "io.confluent:common-utils:7.3.3" - implementation 'org.apache.kafka:kafka-streams:3.6.0' + implementation 'org.apache.kafka:kafka-streams:4.0.0' implementation('org.apache.kafka:kafka-clients') { version { - strictly '3.6.0' + strictly '4.0.0' } } implementation "com.typesafe:config:1.4.2" - testImplementation "org.apache.kafka:kafka-streams-test-utils:3.6.0" + testImplementation "org.apache.kafka:kafka-streams-test-utils:4.0.0" testImplementation 'org.junit.jupiter:junit-jupiter-api:5.9.2' testImplementation 'org.hamcrest:hamcrest:2.2' testRuntimeOnly 'org.junit.platform:junit-platform-launcher' diff --git a/serialization/kstreams/build.gradle b/serialization/kstreams/build.gradle index e5a8eef6..b7875c39 100644 --- a/serialization/kstreams/build.gradle +++ b/serialization/kstreams/build.gradle @@ -20,29 +20,26 @@ java { application { mainClass = "io.confluent.developer.AvroToProtobuf" } - repositories { mavenCentral() maven { url 'https://packages.confluent.io/maven/' } } - dependencies { implementation project(':common') implementation "org.slf4j:slf4j-simple:2.0.7" implementation "org.apache.avro:avro:1.11.1" - implementation "com.google.protobuf:protobuf-java:3.22.2" - implementation 'org.apache.kafka:kafka-streams:3.6.0' - implementation "io.confluent:kafka-streams-avro-serde:7.5.3" - implementation "io.confluent:kafka-streams-protobuf-serde:7.5.3" + implementation "com.google.protobuf:protobuf-java:4.30.0" + implementation 'org.apache.kafka:kafka-streams:4.0.0' + implementation('io.confluent:kafka-streams-protobuf-serde:8.0.0-463') + implementation('io.confluent:kafka-streams-avro-serde:8.0.0-463') implementation('org.apache.kafka:kafka-clients') { version { - strictly '3.6.0' + strictly '4.0.0' } } - implementation "io.confluent:kafka-streams-avro-serde:7.5.1" implementation "com.typesafe:config:1.4.2" - testImplementation "org.apache.kafka:kafka-streams-test-utils:3.6.0" + testImplementation "org.apache.kafka:kafka-streams-test-utils:4.0.0" testImplementation 'org.junit.jupiter:junit-jupiter-api:5.9.2' testImplementation 'org.hamcrest:hamcrest:2.2' testRuntimeOnly 'org.junit.platform:junit-platform-launcher' @@ -73,10 +70,7 @@ shadowJar { } protobuf { - generatedFilesBaseDir = "$buildDir/generated-main-proto-java/" - protoc { - artifact = "com.google.protobuf:protoc:3.22.2" + artifact = "com.google.protobuf:protoc:4.30.0" } - } diff --git a/session-windows/kstreams/build.gradle b/session-windows/kstreams/build.gradle index d0f01aef..82a55603 100644 --- a/session-windows/kstreams/build.gradle +++ b/session-windows/kstreams/build.gradle @@ -36,16 +36,16 @@ repositories { dependencies { implementation project(':common') implementation "org.slf4j:slf4j-simple:2.0.7" - implementation 'org.apache.kafka:kafka-streams:3.6.0' + implementation 'org.apache.kafka:kafka-streams:4.0.0' implementation('org.apache.kafka:kafka-clients') { version { - strictly '3.6.0' + strictly '4.0.0' } } implementation "io.confluent:kafka-streams-avro-serde:7.5.1" implementation "com.typesafe:config:1.4.2" - testImplementation "org.apache.kafka:kafka-streams-test-utils:3.6.0" + testImplementation "org.apache.kafka:kafka-streams-test-utils:4.0.0" testImplementation 'org.junit.jupiter:junit-jupiter-api:5.9.2' testImplementation 'org.hamcrest:hamcrest:2.2' testRuntimeOnly 'org.junit.platform:junit-platform-launcher' diff --git a/sliding-windows/kstreams/build.gradle b/sliding-windows/kstreams/build.gradle index 3bed79d0..ae4393c7 100644 --- a/sliding-windows/kstreams/build.gradle +++ b/sliding-windows/kstreams/build.gradle @@ -36,16 +36,16 @@ repositories { dependencies { implementation project(':common') implementation "org.slf4j:slf4j-simple:2.0.7" - implementation 'org.apache.kafka:kafka-streams:3.6.0' + implementation 'org.apache.kafka:kafka-streams:4.0.0' implementation('org.apache.kafka:kafka-clients') { version { - strictly '3.6.0' + strictly '4.0.0' } } implementation "io.confluent:kafka-streams-avro-serde:7.5.1" implementation "com.typesafe:config:1.4.2" - testImplementation "org.apache.kafka:kafka-streams-test-utils:3.6.0" + testImplementation "org.apache.kafka:kafka-streams-test-utils:4.0.0" testImplementation 'org.junit.jupiter:junit-jupiter-api:5.9.2' testImplementation 'org.hamcrest:hamcrest:2.2' testRuntimeOnly 'org.junit.platform:junit-platform-launcher' diff --git a/splitting/kstreams/build.gradle b/splitting/kstreams/build.gradle index 408d05fc..b00a831e 100644 --- a/splitting/kstreams/build.gradle +++ b/splitting/kstreams/build.gradle @@ -27,16 +27,16 @@ repositories { dependencies { implementation project(':common') implementation "org.slf4j:slf4j-simple:2.0.7" - implementation 'org.apache.kafka:kafka-streams:3.6.0' + implementation 'org.apache.kafka:kafka-streams:4.0.0' implementation('org.apache.kafka:kafka-clients') { version { - strictly '3.6.0' + strictly '4.0.0' } } implementation "io.confluent:kafka-streams-avro-serde:7.5.1" implementation "com.typesafe:config:1.4.2" - testImplementation "org.apache.kafka:kafka-streams-test-utils:3.6.0" + testImplementation "org.apache.kafka:kafka-streams-test-utils:4.0.0" testImplementation 'org.junit.jupiter:junit-jupiter-api:5.9.2' testImplementation 'org.hamcrest:hamcrest:2.2' testRuntimeOnly 'org.junit.platform:junit-platform-launcher' diff --git a/streams-to-table/kstreams/build.gradle b/streams-to-table/kstreams/build.gradle index 7eb1029c..8ae3a56c 100644 --- a/streams-to-table/kstreams/build.gradle +++ b/streams-to-table/kstreams/build.gradle @@ -27,16 +27,16 @@ repositories { dependencies { implementation project(':common') implementation "org.slf4j:slf4j-simple:2.0.7" - implementation 'org.apache.kafka:kafka-streams:3.6.0' + implementation 'org.apache.kafka:kafka-streams:4.0.0' implementation('org.apache.kafka:kafka-clients') { version { - strictly '3.6.0' + strictly '4.0.0' } } implementation "io.confluent:kafka-streams-avro-serde:7.5.1" implementation "com.typesafe:config:1.4.2" - testImplementation "org.apache.kafka:kafka-streams-test-utils:3.6.0" + testImplementation "org.apache.kafka:kafka-streams-test-utils:4.0.0" testImplementation 'org.junit.jupiter:junit-jupiter-api:5.9.2' testImplementation 'org.hamcrest:hamcrest:2.2' testRuntimeOnly 'org.junit.platform:junit-platform-launcher' diff --git a/transforming/kstreams/build.gradle b/transforming/kstreams/build.gradle index 73e3f7ba..6df2c797 100644 --- a/transforming/kstreams/build.gradle +++ b/transforming/kstreams/build.gradle @@ -27,16 +27,16 @@ repositories { dependencies { implementation project(':common') implementation "org.slf4j:slf4j-simple:2.0.7" - implementation 'org.apache.kafka:kafka-streams:3.6.0' + implementation 'org.apache.kafka:kafka-streams:4.0.0' implementation('org.apache.kafka:kafka-clients') { version { - strictly '3.6.0' + strictly '4.0.0' } } implementation "io.confluent:kafka-streams-avro-serde:7.5.1" implementation "com.typesafe:config:1.4.2" - testImplementation "org.apache.kafka:kafka-streams-test-utils:3.6.0" + testImplementation "org.apache.kafka:kafka-streams-test-utils:4.0.0" testImplementation 'org.junit.jupiter:junit-jupiter-api:5.9.2' testImplementation 'org.hamcrest:hamcrest:2.2' testRuntimeOnly 'org.junit.platform:junit-platform-launcher' diff --git a/tumbling-windows/kstreams/build.gradle b/tumbling-windows/kstreams/build.gradle index 135b6ac6..5b0ef3f5 100644 --- a/tumbling-windows/kstreams/build.gradle +++ b/tumbling-windows/kstreams/build.gradle @@ -36,16 +36,16 @@ repositories { dependencies { implementation project(':common') implementation "org.slf4j:slf4j-simple:2.0.7" - implementation 'org.apache.kafka:kafka-streams:3.6.0' + implementation 'org.apache.kafka:kafka-streams:4.0.0' implementation('org.apache.kafka:kafka-clients') { version { - strictly '3.6.0' + strictly '4.0.0' } } implementation "io.confluent:kafka-streams-avro-serde:7.5.1" implementation "com.typesafe:config:1.4.2" - testImplementation "org.apache.kafka:kafka-streams-test-utils:3.6.0" + testImplementation "org.apache.kafka:kafka-streams-test-utils:4.0.0" testImplementation 'org.junit.jupiter:junit-jupiter-api:5.9.2' testImplementation 'org.hamcrest:hamcrest:2.2' testRuntimeOnly 'org.junit.platform:junit-platform-launcher' diff --git a/versioned-ktables/kstreams/build.gradle b/versioned-ktables/kstreams/build.gradle index 3f4e96cb..388277dd 100644 --- a/versioned-ktables/kstreams/build.gradle +++ b/versioned-ktables/kstreams/build.gradle @@ -28,16 +28,16 @@ repositories { dependencies { implementation project(':common') implementation "org.slf4j:slf4j-simple:2.0.7" - implementation 'org.apache.kafka:kafka-streams:3.6.0' + implementation 'org.apache.kafka:kafka-streams:4.0.0' implementation('org.apache.kafka:kafka-clients') { version { - strictly '3.6.0' + strictly '4.0.0' } } implementation "io.confluent:kafka-streams-avro-serde:7.5.1" implementation "com.typesafe:config:1.4.2" - testImplementation "org.apache.kafka:kafka-streams-test-utils:3.6.0" + testImplementation "org.apache.kafka:kafka-streams-test-utils:4.0.0" testImplementation 'org.junit.jupiter:junit-jupiter-api:5.9.2' testImplementation 'org.hamcrest:hamcrest:2.2' testRuntimeOnly 'org.junit.platform:junit-platform-launcher' diff --git a/window-final-result/kstreams/build.gradle b/window-final-result/kstreams/build.gradle index 05e4ab38..b29b30d3 100644 --- a/window-final-result/kstreams/build.gradle +++ b/window-final-result/kstreams/build.gradle @@ -28,16 +28,16 @@ repositories { dependencies { implementation project(':common') implementation "org.slf4j:slf4j-simple:2.0.7" - implementation 'org.apache.kafka:kafka-streams:3.6.0' + implementation 'org.apache.kafka:kafka-streams:4.0.0' implementation('org.apache.kafka:kafka-clients') { version { - strictly '3.6.0' + strictly '4.0.0' } } implementation "io.confluent:kafka-streams-avro-serde:7.5.1" implementation "com.typesafe:config:1.4.2" - testImplementation "org.apache.kafka:kafka-streams-test-utils:3.6.0" + testImplementation "org.apache.kafka:kafka-streams-test-utils:4.0.0" testImplementation 'org.junit.jupiter:junit-jupiter-api:5.9.2' testImplementation 'org.hamcrest:hamcrest:2.2' testRuntimeOnly 'org.junit.platform:junit-platform-launcher' From 7501749bbf39808fbe8bbb3bf95ace2ff8408275 Mon Sep 17 00:00:00 2001 From: Dave Troiano Date: Wed, 5 Mar 2025 14:42:25 -0500 Subject: [PATCH 2/2] standardize on single quotes in gradle files --- aggregating-average/kstreams/build.gradle | 22 +++---- aggregating-count/flinksql/build.gradle | 2 +- aggregating-count/kstreams/build.gradle | 22 +++---- aggregating-minmax/flinksql/build.gradle | 2 +- aggregating-minmax/kstreams/build.gradle | 20 +++---- aggregating-sum/kstreams/build.gradle | 20 +++---- array-expansion/flinksql/build.gradle | 2 +- build.gradle | 6 +- .../kafka/build.gradle | 22 +++---- cogrouping-streams/kstreams/build.gradle | 22 +++---- common/build.gradle | 2 +- .../kafka/build.gradle | 22 +++---- .../kstreams/build.gradle | 20 +++---- deduplication-windowed/flinksql/build.gradle | 2 +- deduplication-windowed/kstreams/build.gradle | 16 ++--- deduplication/flinksql/build.gradle | 2 +- dynamic-output-topic/kstreams/build.gradle | 20 +++---- error-handling/kstreams/build.gradle | 22 +++---- filtering/flink_table_api_java/build.gradle | 2 +- filtering/flinksql/build.gradle | 2 +- filtering/kstreams/build.gradle | 14 ++--- fk-joins/kstreams/build.gradle | 18 +++--- hopping-windows/flinksql/build.gradle | 2 +- joining-stream-stream/flinksql/build.gradle | 2 +- joining-stream-stream/kstreams/build.gradle | 16 ++--- joining-stream-table/kstreams/build.gradle | 16 ++--- joining-table-table/kstreams/build.gradle | 16 ++--- kafka-consumer-application/kafka/build.gradle | 16 ++--- .../kafka/build.gradle | 16 ++--- kafka-producer-application/kafka/build.gradle | 24 ++++---- .../kstreams/build.gradle | 20 +++---- lagging-events/flinksql/build.gradle | 2 +- merging/flinksql/build.gradle | 2 +- merging/kstreams/build.gradle | 20 +++---- multi-joins/flinksql/build.gradle | 2 +- multiple-event-types-avro/kafka/build.gradle | 60 +++++++++---------- .../kafka/build.gradle | 40 ++++++------- .../kstreams/build.gradle | 22 +++---- over-aggregations/flinksql/build.gradle | 2 +- pattern-matching/flinksql/build.gradle | 2 +- reordering-streams/kstreams/build.gradle | 18 +++--- .../kstreams/build.gradle | 22 +++---- schedule-ktable-ttl/kstreams/build.gradle | 22 +++---- serialization/kstreams/build.gradle | 30 +++++----- session-windows/flinksql/build.gradle | 2 +- session-windows/kstreams/build.gradle | 22 +++---- sliding-windows/kstreams/build.gradle | 22 +++---- sorting/flinksql/build.gradle | 2 +- splitting/flinksql/build.gradle | 2 +- splitting/kstreams/build.gradle | 22 +++---- streams-to-table/kstreams/build.gradle | 22 +++---- top-N/flinksql/build.gradle | 2 +- transforming/kstreams/build.gradle | 22 +++---- tumbling-windows/flinksql/build.gradle | 2 +- tumbling-windows/kstreams/build.gradle | 22 +++---- udf/ksql/build.gradle | 12 ++-- versioned-ktables/kstreams/build.gradle | 24 ++++---- window-final-result/kstreams/build.gradle | 22 +++---- windowed-top-N/flinksql/build.gradle | 2 +- 59 files changed, 428 insertions(+), 428 deletions(-) diff --git a/aggregating-average/kstreams/build.gradle b/aggregating-average/kstreams/build.gradle index d4189f66..abafd411 100644 --- a/aggregating-average/kstreams/build.gradle +++ b/aggregating-average/kstreams/build.gradle @@ -5,8 +5,8 @@ buildscript { } plugins { - id "java" - id "application" + id 'java' + id 'application' id 'com.github.johnrengelman.shadow' version '8.1.1' } @@ -16,7 +16,7 @@ java { } application { - mainClass = "io.confluent.developer.KafkaStreamsRunningAverage" + mainClass = 'io.confluent.developer.KafkaStreamsRunningAverage' } repositories { @@ -27,17 +27,17 @@ repositories { dependencies { implementation project(':common') - implementation "org.slf4j:slf4j-simple:2.0.7" + implementation 'org.slf4j:slf4j-simple:2.0.7' implementation 'org.apache.kafka:kafka-streams:4.0.0' implementation('org.apache.kafka:kafka-clients') { version { strictly '4.0.0' } } - implementation "io.confluent:kafka-streams-avro-serde:7.5.1" - implementation "com.typesafe:config:1.4.2" + implementation 'io.confluent:kafka-streams-avro-serde:7.5.1' + implementation 'com.typesafe:config:1.4.2' - testImplementation "org.apache.kafka:kafka-streams-test-utils:4.0.0" + testImplementation 'org.apache.kafka:kafka-streams-test-utils:4.0.0' testImplementation 'org.junit.jupiter:junit-jupiter-api:5.9.2' testImplementation 'org.hamcrest:hamcrest:2.2' testRuntimeOnly 'org.junit.platform:junit-platform-launcher' @@ -49,20 +49,20 @@ test { testLogging { outputs.upToDateWhen { false } showStandardStreams = true - events "PASSED", "SKIPPED", "FAILED", "STANDARD_OUT", "STANDARD_ERROR" - exceptionFormat = "full" + events 'PASSED', 'SKIPPED', 'FAILED', 'STANDARD_OUT', 'STANDARD_ERROR' + exceptionFormat = 'full' } } jar { manifest { attributes( - "Class-Path": configurations.runtimeClasspath.collect { it.getName() }.join(" ") + 'Class-Path': configurations.runtimeClasspath.collect { it.getName() }.join(' ') ) } } shadowJar { - archiveBaseName = "aggregating-average-standalone" + archiveBaseName = 'aggregating-average-standalone' archiveClassifier = '' } diff --git a/aggregating-count/flinksql/build.gradle b/aggregating-count/flinksql/build.gradle index f9ac8e4b..f412f3d9 100644 --- a/aggregating-count/flinksql/build.gradle +++ b/aggregating-count/flinksql/build.gradle @@ -14,7 +14,7 @@ java { targetCompatibility = JavaVersion.VERSION_17 } -version = "0.0.1" +version = '0.0.1' repositories { mavenCentral() diff --git a/aggregating-count/kstreams/build.gradle b/aggregating-count/kstreams/build.gradle index da4c21cd..44e56e64 100644 --- a/aggregating-count/kstreams/build.gradle +++ b/aggregating-count/kstreams/build.gradle @@ -5,8 +5,8 @@ buildscript { } plugins { - id "java" - id "application" + id 'java' + id 'application' id 'com.github.johnrengelman.shadow' version '8.1.1' } @@ -16,7 +16,7 @@ java { } application { - mainClass = "io.confluent.developer.KafkaStreamsAggregatingCount" + mainClass = 'io.confluent.developer.KafkaStreamsAggregatingCount' } repositories { @@ -26,17 +26,17 @@ repositories { dependencies { implementation project(':common') - implementation "org.slf4j:slf4j-simple:2.0.7" + implementation 'org.slf4j:slf4j-simple:2.0.7' implementation 'org.apache.kafka:kafka-streams:4.0.0' implementation('org.apache.kafka:kafka-clients') { version { strictly '4.0.0' } } - implementation "io.confluent:kafka-streams-avro-serde:7.5.1" - implementation "com.typesafe:config:1.4.2" + implementation 'io.confluent:kafka-streams-avro-serde:7.5.1' + implementation 'com.typesafe:config:1.4.2' - testImplementation "org.apache.kafka:kafka-streams-test-utils:4.0.0" + testImplementation 'org.apache.kafka:kafka-streams-test-utils:4.0.0' testImplementation 'org.junit.jupiter:junit-jupiter-api:5.9.2' testImplementation 'org.hamcrest:hamcrest:2.2' testRuntimeOnly 'org.junit.platform:junit-platform-launcher' @@ -48,20 +48,20 @@ test { testLogging { outputs.upToDateWhen { false } showStandardStreams = true - events "PASSED", "SKIPPED", "FAILED", "STANDARD_OUT", "STANDARD_ERROR" - exceptionFormat = "full" + events 'PASSED', 'SKIPPED', 'FAILED', 'STANDARD_OUT', 'STANDARD_ERROR' + exceptionFormat = 'full' } } jar { manifest { attributes( - "Class-Path": configurations.runtimeClasspath.collect { it.getName() }.join(" ") + 'Class-Path': configurations.runtimeClasspath.collect { it.getName() }.join(' ') ) } } shadowJar { - archiveBaseName = "aggregating-count-standalone" + archiveBaseName = 'aggregating-count-standalone' archiveClassifier = '' } diff --git a/aggregating-minmax/flinksql/build.gradle b/aggregating-minmax/flinksql/build.gradle index b2b95b81..c860d1b4 100644 --- a/aggregating-minmax/flinksql/build.gradle +++ b/aggregating-minmax/flinksql/build.gradle @@ -13,7 +13,7 @@ java { sourceCompatibility = JavaVersion.VERSION_17 targetCompatibility = JavaVersion.VERSION_17 } -version = "0.0.1" +version = '0.0.1' repositories { mavenCentral() diff --git a/aggregating-minmax/kstreams/build.gradle b/aggregating-minmax/kstreams/build.gradle index d6f7041e..6b49895c 100644 --- a/aggregating-minmax/kstreams/build.gradle +++ b/aggregating-minmax/kstreams/build.gradle @@ -13,8 +13,8 @@ buildscript { } plugins { - id "java" - id "application" + id 'java' + id 'application' id 'com.github.johnrengelman.shadow' version '8.1.1' } @@ -24,7 +24,7 @@ java { } application { - mainClass = "io.confluent.developer.AggregatingMinMax" + mainClass = 'io.confluent.developer.AggregatingMinMax' } repositories { @@ -34,17 +34,17 @@ repositories { dependencies { implementation project(':common') - implementation "org.slf4j:slf4j-simple:2.0.7" + implementation 'org.slf4j:slf4j-simple:2.0.7' implementation 'org.apache.kafka:kafka-streams:4.0.0' implementation('org.apache.kafka:kafka-clients') { version { strictly '4.0.0' } } - implementation "io.confluent:kafka-streams-avro-serde:7.5.1" - implementation "com.typesafe:config:1.4.2" + implementation 'io.confluent:kafka-streams-avro-serde:7.5.1' + implementation 'com.typesafe:config:1.4.2' - testImplementation "org.apache.kafka:kafka-streams-test-utils:4.0.0" + testImplementation 'org.apache.kafka:kafka-streams-test-utils:4.0.0' testImplementation 'org.junit.jupiter:junit-jupiter-api:5.9.2' testImplementation 'org.hamcrest:hamcrest:2.2' testRuntimeOnly 'org.junit.platform:junit-platform-launcher' @@ -56,13 +56,13 @@ test { testLogging { outputs.upToDateWhen { false } showStandardStreams = true - events "PASSED", "SKIPPED", "FAILED", "STANDARD_OUT", "STANDARD_ERROR" - exceptionFormat = "full" + events 'PASSED', 'SKIPPED', 'FAILED', 'STANDARD_OUT', 'STANDARD_ERROR' + exceptionFormat = 'full' } } shadowJar { - archiveBaseName = "aggregating-minmax-standalone" + archiveBaseName = 'aggregating-minmax-standalone' archiveClassifier = '' } diff --git a/aggregating-sum/kstreams/build.gradle b/aggregating-sum/kstreams/build.gradle index 6677297e..43eb8955 100644 --- a/aggregating-sum/kstreams/build.gradle +++ b/aggregating-sum/kstreams/build.gradle @@ -13,8 +13,8 @@ buildscript { } plugins { - id "java" - id "application" + id 'java' + id 'application' id 'com.github.johnrengelman.shadow' version '8.1.1' } @@ -24,7 +24,7 @@ java { } application { - mainClass = "io.confluent.developer.AggregatingSum" + mainClass = 'io.confluent.developer.AggregatingSum' } repositories { @@ -34,17 +34,17 @@ repositories { dependencies { implementation project(':common') - implementation "org.slf4j:slf4j-simple:2.0.7" + implementation 'org.slf4j:slf4j-simple:2.0.7' implementation 'org.apache.kafka:kafka-streams:4.0.0' implementation('org.apache.kafka:kafka-clients') { version { strictly '4.0.0' } } - implementation "io.confluent:kafka-streams-avro-serde:7.5.1" - implementation "com.typesafe:config:1.4.2" + implementation 'io.confluent:kafka-streams-avro-serde:7.5.1' + implementation 'com.typesafe:config:1.4.2' - testImplementation "org.apache.kafka:kafka-streams-test-utils:4.0.0" + testImplementation 'org.apache.kafka:kafka-streams-test-utils:4.0.0' testImplementation 'org.junit.jupiter:junit-jupiter-api:5.9.2' testImplementation 'org.hamcrest:hamcrest:2.2' testRuntimeOnly 'org.junit.platform:junit-platform-launcher' @@ -56,13 +56,13 @@ test { testLogging { outputs.upToDateWhen { false } showStandardStreams = true - events "PASSED", "SKIPPED", "FAILED", "STANDARD_OUT", "STANDARD_ERROR" - exceptionFormat = "full" + events 'PASSED', 'SKIPPED', 'FAILED', 'STANDARD_OUT', 'STANDARD_ERROR' + exceptionFormat = 'full' } } shadowJar { - archiveBaseName = "aggregating-sum-standalone" + archiveBaseName = 'aggregating-sum-standalone' archiveClassifier = '' } diff --git a/array-expansion/flinksql/build.gradle b/array-expansion/flinksql/build.gradle index b2b95b81..c860d1b4 100644 --- a/array-expansion/flinksql/build.gradle +++ b/array-expansion/flinksql/build.gradle @@ -13,7 +13,7 @@ java { sourceCompatibility = JavaVersion.VERSION_17 targetCompatibility = JavaVersion.VERSION_17 } -version = "0.0.1" +version = '0.0.1' repositories { mavenCentral() diff --git a/build.gradle b/build.gradle index 570a6084..f580eeb1 100644 --- a/build.gradle +++ b/build.gradle @@ -12,7 +12,7 @@ allprojects { repositories { mavenCentral() maven { - url = uri("https://repository.apache.org/content/groups/staging/") + url = uri('https://repository.apache.org/content/groups/staging/') } maven { url 'https://packages.confluent.io/maven/' } } @@ -33,8 +33,8 @@ subprojects { tasks.withType(Test) { testLogging { outputs.upToDateWhen { false } - events "PASSED", "SKIPPED", "FAILED", "STANDARD_OUT", "STANDARD_ERROR" - exceptionFormat = "full" + events 'PASSED', 'SKIPPED', 'FAILED', 'STANDARD_OUT', 'STANDARD_ERROR' + exceptionFormat = 'full' } } } diff --git a/client-telemetry-reporter-plugin/kafka/build.gradle b/client-telemetry-reporter-plugin/kafka/build.gradle index 3492aafb..3d1bd214 100644 --- a/client-telemetry-reporter-plugin/kafka/build.gradle +++ b/client-telemetry-reporter-plugin/kafka/build.gradle @@ -5,7 +5,7 @@ buildscript { } plugins { - id "java" + id 'java' id 'com.github.johnrengelman.shadow' version '8.1.1' } @@ -21,12 +21,12 @@ repositories { dependencies { implementation project(':common') - implementation "org.slf4j:slf4j-simple:2.0.7" - implementation "io.opentelemetry.proto:opentelemetry-proto:1.0.0-alpha" - implementation "io.grpc:grpc-api:1.66.0" - implementation "io.grpc:grpc-netty-shaded:1.66.0" - implementation "io.grpc:grpc-protobuf:1.66.0" - implementation "io.grpc:grpc-stub:1.66.0" + implementation 'org.slf4j:slf4j-simple:2.0.7' + implementation 'io.opentelemetry.proto:opentelemetry-proto:1.0.0-alpha' + implementation 'io.grpc:grpc-api:1.66.0' + implementation 'io.grpc:grpc-netty-shaded:1.66.0' + implementation 'io.grpc:grpc-protobuf:1.66.0' + implementation 'io.grpc:grpc-stub:1.66.0' implementation('org.apache.kafka:kafka-clients') { version { strictly '4.0.0' @@ -39,8 +39,8 @@ test { testLogging { outputs.upToDateWhen { false } showStandardStreams = true - events "PASSED", "SKIPPED", "FAILED", "STANDARD_OUT", "STANDARD_ERROR" - exceptionFormat = "full" + events 'PASSED', 'SKIPPED', 'FAILED', 'STANDARD_OUT', 'STANDARD_ERROR' + exceptionFormat = 'full' } } @@ -50,7 +50,7 @@ jar { } shadowJar { - archiveBaseName = "client-telemetry-reporter-plugin" + archiveBaseName = 'client-telemetry-reporter-plugin' archiveClassifier = '' mergeServiceFiles() @@ -63,6 +63,6 @@ shadowJar { dependencies { exclude(dependency('org.apache.kafka:kafka-clients')) // exclude proto files from the jar - exclude "**/opentelemetry/proto/**/*.proto" + exclude '**/opentelemetry/proto/**/*.proto' } } diff --git a/cogrouping-streams/kstreams/build.gradle b/cogrouping-streams/kstreams/build.gradle index 64cea6b5..e7ccba8b 100644 --- a/cogrouping-streams/kstreams/build.gradle +++ b/cogrouping-streams/kstreams/build.gradle @@ -13,8 +13,8 @@ buildscript { } plugins { - id "java" - id "application" + id 'java' + id 'application' id 'com.github.johnrengelman.shadow' version '8.1.1' } @@ -24,7 +24,7 @@ java { } application { - mainClass = "io.confluent.developer.CogroupingStreams" + mainClass = 'io.confluent.developer.CogroupingStreams' } repositories { @@ -35,17 +35,17 @@ repositories { dependencies { implementation project(':common') - implementation "org.slf4j:slf4j-simple:2.0.7" + implementation 'org.slf4j:slf4j-simple:2.0.7' implementation 'org.apache.kafka:kafka-streams:4.0.0' implementation('org.apache.kafka:kafka-clients') { version { strictly '4.0.0' } } - implementation "io.confluent:kafka-streams-avro-serde:7.5.1" - implementation "com.typesafe:config:1.4.2" + implementation 'io.confluent:kafka-streams-avro-serde:7.5.1' + implementation 'com.typesafe:config:1.4.2' - testImplementation "org.apache.kafka:kafka-streams-test-utils:4.0.0" + testImplementation 'org.apache.kafka:kafka-streams-test-utils:4.0.0' testImplementation 'org.junit.jupiter:junit-jupiter-api:5.9.2' testImplementation 'org.hamcrest:hamcrest:2.2' testRuntimeOnly 'org.junit.platform:junit-platform-launcher' @@ -57,20 +57,20 @@ test { testLogging { outputs.upToDateWhen { false } showStandardStreams = true - events "PASSED", "SKIPPED", "FAILED", "STANDARD_OUT", "STANDARD_ERROR" - exceptionFormat = "full" + events 'PASSED', 'SKIPPED', 'FAILED', 'STANDARD_OUT', 'STANDARD_ERROR' + exceptionFormat = 'full' } } jar { manifest { attributes( - "Class-Path": configurations.runtimeClasspath.collect { it.getName() }.join(" ") + 'Class-Path': configurations.runtimeClasspath.collect { it.getName() }.join(' ') ) } } shadowJar { - archiveBaseName = "cogrouping-standalone" + archiveBaseName = 'cogrouping-standalone' archiveClassifier = '' } diff --git a/common/build.gradle b/common/build.gradle index 70514d39..5533ea1f 100644 --- a/common/build.gradle +++ b/common/build.gradle @@ -17,7 +17,7 @@ configurations { task testJar(type: Jar) { from sourceSets.test.output - archiveClassifier.set("test") + archiveClassifier.set('test') } artifacts { diff --git a/confluent-parallel-consumer-application/kafka/build.gradle b/confluent-parallel-consumer-application/kafka/build.gradle index 38e60c89..4baf46b5 100644 --- a/confluent-parallel-consumer-application/kafka/build.gradle +++ b/confluent-parallel-consumer-application/kafka/build.gradle @@ -13,7 +13,7 @@ buildscript { } plugins { - id "java" + id 'java' id 'com.github.johnrengelman.shadow' version '8.1.1' } @@ -30,18 +30,18 @@ repositories { dependencies { implementation project(':common') - implementation "org.slf4j:slf4j-simple:2.0.7" - implementation "io.confluent.parallelconsumer:parallel-consumer-core:0.5.3.2" - implementation "org.apache.commons:commons-lang3:3.12.0" - implementation "me.tongfei:progressbar:0.9.3" + implementation 'org.slf4j:slf4j-simple:2.0.7' + implementation 'io.confluent.parallelconsumer:parallel-consumer-core:0.5.3.2' + implementation 'org.apache.commons:commons-lang3:3.12.0' + implementation 'me.tongfei:progressbar:0.9.3' implementation 'org.awaitility:awaitility:4.2.0' - implementation "com.typesafe:config:1.4.2" + implementation 'com.typesafe:config:1.4.2' testImplementation 'org.junit.jupiter:junit-jupiter-api:5.9.2' testImplementation 'org.hamcrest:hamcrest:2.2' testImplementation 'org.awaitility:awaitility:4.2.0' - testImplementation "io.confluent.parallelconsumer:parallel-consumer-core:0.5.3.2:tests" // for LongPollingMockConsumer + testImplementation 'io.confluent.parallelconsumer:parallel-consumer-core:0.5.3.2:tests' // for LongPollingMockConsumer testRuntimeOnly 'org.junit.platform:junit-platform-launcher' testRuntimeOnly 'org.junit.jupiter:junit-jupiter-engine:5.9.2' } @@ -51,20 +51,20 @@ test { testLogging { outputs.upToDateWhen { false } showStandardStreams = true - events "PASSED", "SKIPPED", "FAILED", "STANDARD_OUT", "STANDARD_ERROR" - exceptionFormat = "full" + events 'PASSED', 'SKIPPED', 'FAILED', 'STANDARD_OUT', 'STANDARD_ERROR' + exceptionFormat = 'full' } } jar { manifest { attributes( - "Class-Path": configurations.runtimeClasspath.collect { it.getName() }.join(" ") + 'Class-Path': configurations.runtimeClasspath.collect { it.getName() }.join(' ') ) } } shadowJar { - archiveBaseName = "parallel-consumer-standalone" + archiveBaseName = 'parallel-consumer-standalone' archiveClassifier = '' } diff --git a/creating-first-apache-kafka-streams-application/kstreams/build.gradle b/creating-first-apache-kafka-streams-application/kstreams/build.gradle index e2b715a8..cd6147f0 100644 --- a/creating-first-apache-kafka-streams-application/kstreams/build.gradle +++ b/creating-first-apache-kafka-streams-application/kstreams/build.gradle @@ -13,8 +13,8 @@ buildscript { } plugins { - id "java" - id "application" + id 'java' + id 'application' id 'com.github.johnrengelman.shadow' version '8.1.1' } @@ -24,7 +24,7 @@ java { } application { - mainClass = "io.confluent.developer.KafkaStreamsApplication" + mainClass = 'io.confluent.developer.KafkaStreamsApplication' } repositories { @@ -35,16 +35,16 @@ repositories { dependencies { implementation project(':common') - implementation "org.slf4j:slf4j-simple:2.0.7" + implementation 'org.slf4j:slf4j-simple:2.0.7' implementation 'org.apache.kafka:kafka-streams:4.0.0' implementation('org.apache.kafka:kafka-clients') { version { strictly '4.0.0' } } - implementation "io.confluent:kafka-streams-avro-serde:7.5.1" + implementation 'io.confluent:kafka-streams-avro-serde:7.5.1' - testImplementation "org.apache.kafka:kafka-streams-test-utils:4.0.0" + testImplementation 'org.apache.kafka:kafka-streams-test-utils:4.0.0' testImplementation 'org.junit.jupiter:junit-jupiter-api:5.9.2' testImplementation 'org.hamcrest:hamcrest:2.2' testRuntimeOnly 'org.junit.platform:junit-platform-launcher' @@ -56,21 +56,21 @@ test { testLogging { outputs.upToDateWhen { false } showStandardStreams = true - events "PASSED", "SKIPPED", "FAILED", "STANDARD_OUT", "STANDARD_ERROR" - exceptionFormat = "full" + events 'PASSED', 'SKIPPED', 'FAILED', 'STANDARD_OUT', 'STANDARD_ERROR' + exceptionFormat = 'full' } } jar { manifest { attributes( - "Class-Path": configurations.runtimeClasspath.collect { it.getName() }.join(" ") + 'Class-Path': configurations.runtimeClasspath.collect { it.getName() }.join(' ') ) } } shadowJar { - archiveBaseName = "creating-first-apache-kafka-streams-application-standalone" + archiveBaseName = 'creating-first-apache-kafka-streams-application-standalone' archiveClassifier = '' } diff --git a/deduplication-windowed/flinksql/build.gradle b/deduplication-windowed/flinksql/build.gradle index b2b95b81..c860d1b4 100644 --- a/deduplication-windowed/flinksql/build.gradle +++ b/deduplication-windowed/flinksql/build.gradle @@ -13,7 +13,7 @@ java { sourceCompatibility = JavaVersion.VERSION_17 targetCompatibility = JavaVersion.VERSION_17 } -version = "0.0.1" +version = '0.0.1' repositories { mavenCentral() diff --git a/deduplication-windowed/kstreams/build.gradle b/deduplication-windowed/kstreams/build.gradle index a4640141..1b6dc028 100644 --- a/deduplication-windowed/kstreams/build.gradle +++ b/deduplication-windowed/kstreams/build.gradle @@ -5,8 +5,8 @@ buildscript { } plugins { - id "java" - id "application" + id 'java' + id 'application' id 'com.github.johnrengelman.shadow' version '8.1.1' } @@ -16,7 +16,7 @@ java { } application { - mainClass = "io.confluent.developer.FindDistinctEvents" + mainClass = 'io.confluent.developer.FindDistinctEvents' } repositories { @@ -26,7 +26,7 @@ repositories { dependencies { implementation project(':common') - implementation "org.slf4j:slf4j-simple:2.0.7" + implementation 'org.slf4j:slf4j-simple:2.0.7' implementation 'org.apache.kafka:kafka-streams:4.0.0' implementation('org.apache.kafka:kafka-clients') { version { @@ -34,7 +34,7 @@ dependencies { } } - testImplementation "org.apache.kafka:kafka-streams-test-utils:4.0.0" + testImplementation 'org.apache.kafka:kafka-streams-test-utils:4.0.0' testImplementation 'org.junit.jupiter:junit-jupiter-api:5.9.2' testImplementation 'org.hamcrest:hamcrest:2.2' testRuntimeOnly 'org.junit.platform:junit-platform-launcher' @@ -46,12 +46,12 @@ test { testLogging { outputs.upToDateWhen { false } showStandardStreams = true - events "PASSED", "SKIPPED", "FAILED", "STANDARD_OUT", "STANDARD_ERROR" - exceptionFormat = "full" + events 'PASSED', 'SKIPPED', 'FAILED', 'STANDARD_OUT', 'STANDARD_ERROR' + exceptionFormat = 'full' } } shadowJar { - archiveBaseName = "find-distinct-standalone" + archiveBaseName = 'find-distinct-standalone' archiveClassifier = '' } diff --git a/deduplication/flinksql/build.gradle b/deduplication/flinksql/build.gradle index b2b95b81..c860d1b4 100644 --- a/deduplication/flinksql/build.gradle +++ b/deduplication/flinksql/build.gradle @@ -13,7 +13,7 @@ java { sourceCompatibility = JavaVersion.VERSION_17 targetCompatibility = JavaVersion.VERSION_17 } -version = "0.0.1" +version = '0.0.1' repositories { mavenCentral() diff --git a/dynamic-output-topic/kstreams/build.gradle b/dynamic-output-topic/kstreams/build.gradle index 6f23f3b6..de3d0463 100644 --- a/dynamic-output-topic/kstreams/build.gradle +++ b/dynamic-output-topic/kstreams/build.gradle @@ -5,8 +5,8 @@ buildscript { } plugins { - id "java" - id "application" + id 'java' + id 'application' id 'com.github.johnrengelman.shadow' version '8.1.1' } @@ -16,7 +16,7 @@ java { } application { - mainClass = "io.confluent.developer.DynamicOutputTopic" + mainClass = 'io.confluent.developer.DynamicOutputTopic' } repositories { @@ -26,17 +26,17 @@ repositories { dependencies { implementation project(':common') - implementation "org.slf4j:slf4j-simple:2.0.7" + implementation 'org.slf4j:slf4j-simple:2.0.7' implementation 'org.apache.kafka:kafka-streams:4.0.0' implementation('org.apache.kafka:kafka-clients') { version { strictly '4.0.0' } } - implementation "io.confluent:kafka-streams-avro-serde:7.5.1" - implementation "com.typesafe:config:1.4.2" + implementation 'io.confluent:kafka-streams-avro-serde:7.5.1' + implementation 'com.typesafe:config:1.4.2' - testImplementation "org.apache.kafka:kafka-streams-test-utils:4.0.0" + testImplementation 'org.apache.kafka:kafka-streams-test-utils:4.0.0' testImplementation 'org.junit.jupiter:junit-jupiter-api:5.9.2' testImplementation 'org.hamcrest:hamcrest:2.2' testRuntimeOnly 'org.junit.platform:junit-platform-launcher' @@ -48,12 +48,12 @@ test { testLogging { outputs.upToDateWhen { false } showStandardStreams = true - events "PASSED", "SKIPPED", "FAILED", "STANDARD_OUT", "STANDARD_ERROR" - exceptionFormat = "full" + events 'PASSED', 'SKIPPED', 'FAILED', 'STANDARD_OUT', 'STANDARD_ERROR' + exceptionFormat = 'full' } } shadowJar { - archiveBaseName = "dynamic-output-topic-standalone" + archiveBaseName = 'dynamic-output-topic-standalone' archiveClassifier = '' } diff --git a/error-handling/kstreams/build.gradle b/error-handling/kstreams/build.gradle index 4356db62..a4b88e96 100644 --- a/error-handling/kstreams/build.gradle +++ b/error-handling/kstreams/build.gradle @@ -13,8 +13,8 @@ buildscript { } plugins { - id "java" - id "application" + id 'java' + id 'application' id 'com.github.johnrengelman.shadow' version '8.1.1' } @@ -24,7 +24,7 @@ java { } application { - mainClass = "io.confluent.developer.StreamsUncaughtExceptionHandling" + mainClass = 'io.confluent.developer.StreamsUncaughtExceptionHandling' } repositories { @@ -35,17 +35,17 @@ repositories { dependencies { implementation project(':common') - implementation "org.slf4j:slf4j-simple:2.0.7" + implementation 'org.slf4j:slf4j-simple:2.0.7' implementation 'org.apache.kafka:kafka-streams:4.0.0' implementation('org.apache.kafka:kafka-clients') { version { strictly '4.0.0' } } - implementation "io.confluent:kafka-streams-avro-serde:7.5.1" - implementation "com.typesafe:config:1.4.2" + implementation 'io.confluent:kafka-streams-avro-serde:7.5.1' + implementation 'com.typesafe:config:1.4.2' - testImplementation "org.apache.kafka:kafka-streams-test-utils:4.0.0" + testImplementation 'org.apache.kafka:kafka-streams-test-utils:4.0.0' testImplementation 'org.junit.jupiter:junit-jupiter-api:5.9.2' testImplementation 'org.hamcrest:hamcrest:2.2' testRuntimeOnly 'org.junit.platform:junit-platform-launcher' @@ -57,20 +57,20 @@ test { testLogging { outputs.upToDateWhen { false } showStandardStreams = true - events "PASSED", "SKIPPED", "FAILED", "STANDARD_OUT", "STANDARD_ERROR" - exceptionFormat = "full" + events 'PASSED', 'SKIPPED', 'FAILED', 'STANDARD_OUT', 'STANDARD_ERROR' + exceptionFormat = 'full' } } jar { manifest { attributes( - "Class-Path": configurations.runtimeClasspath.collect { it.getName() }.join(" ") + 'Class-Path': configurations.runtimeClasspath.collect { it.getName() }.join(' ') ) } } shadowJar { - archiveBaseName = "error-handling-standalone" + archiveBaseName = 'error-handling-standalone' archiveClassifier = '' } diff --git a/filtering/flink_table_api_java/build.gradle b/filtering/flink_table_api_java/build.gradle index 32ce943b..d65dcf41 100644 --- a/filtering/flink_table_api_java/build.gradle +++ b/filtering/flink_table_api_java/build.gradle @@ -15,7 +15,7 @@ java { } application { - mainClass = "io.confluent.developer.FlinkTableApiFiltering" + mainClass = 'io.confluent.developer.FlinkTableApiFiltering' } repositories { diff --git a/filtering/flinksql/build.gradle b/filtering/flinksql/build.gradle index b2b95b81..c860d1b4 100644 --- a/filtering/flinksql/build.gradle +++ b/filtering/flinksql/build.gradle @@ -13,7 +13,7 @@ java { sourceCompatibility = JavaVersion.VERSION_17 targetCompatibility = JavaVersion.VERSION_17 } -version = "0.0.1" +version = '0.0.1' repositories { mavenCentral() diff --git a/filtering/kstreams/build.gradle b/filtering/kstreams/build.gradle index 76c58e7b..c0cfc46a 100644 --- a/filtering/kstreams/build.gradle +++ b/filtering/kstreams/build.gradle @@ -16,7 +16,7 @@ java { } application { - mainClass = "io.confluent.developer.FilterEvents" + mainClass = 'io.confluent.developer.FilterEvents' } repositories { @@ -26,14 +26,14 @@ repositories { dependencies { implementation project(':common') - implementation "org.slf4j:slf4j-simple:2.0.7" + implementation 'org.slf4j:slf4j-simple:2.0.7' implementation 'org.apache.kafka:kafka-streams:4.0.0' implementation ('org.apache.kafka:kafka-clients') { version { strictly '4.0.0' } } - testImplementation "org.apache.kafka:kafka-streams-test-utils:4.0.0" + testImplementation 'org.apache.kafka:kafka-streams-test-utils:4.0.0' testImplementation 'org.junit.jupiter:junit-jupiter-api:5.9.2' testImplementation 'org.hamcrest:hamcrest:2.2' testRuntimeOnly 'org.junit.platform:junit-platform-launcher' @@ -45,20 +45,20 @@ test { testLogging { outputs.upToDateWhen { false } showStandardStreams = true - events "PASSED", "SKIPPED", "FAILED", "STANDARD_OUT", "STANDARD_ERROR" - exceptionFormat = "full" + events 'PASSED', 'SKIPPED', 'FAILED', 'STANDARD_OUT', 'STANDARD_ERROR' + exceptionFormat = 'full' } } jar { manifest { attributes( - "Class-Path": configurations.compileClasspath.collect { it.getName() }.join(" ") + 'Class-Path': configurations.compileClasspath.collect { it.getName() }.join(' ') ) } } shadowJar { - archiveBaseName = "kstreams-filter-standalone" + archiveBaseName = 'kstreams-filter-standalone' archiveClassifier = '' } diff --git a/fk-joins/kstreams/build.gradle b/fk-joins/kstreams/build.gradle index 2963de0b..314d4b00 100644 --- a/fk-joins/kstreams/build.gradle +++ b/fk-joins/kstreams/build.gradle @@ -5,8 +5,8 @@ buildscript { } plugins { - id "java" - id "application" + id 'java' + id 'application' id 'com.github.johnrengelman.shadow' version '8.1.1' } @@ -16,7 +16,7 @@ java { } application { - mainClass = "io.confluent.developer.FkJoinTableToTable" + mainClass = 'io.confluent.developer.FkJoinTableToTable' } repositories { @@ -31,7 +31,7 @@ repositories { dependencies { implementation project(':common') - implementation "org.slf4j:slf4j-simple:2.0.7" + implementation 'org.slf4j:slf4j-simple:2.0.7' implementation 'org.apache.kafka:kafka-streams:4.0.0' implementation('org.apache.kafka:kafka-clients') { version { @@ -39,7 +39,7 @@ dependencies { } } - testImplementation "org.apache.kafka:kafka-streams-test-utils:4.0.0" + testImplementation 'org.apache.kafka:kafka-streams-test-utils:4.0.0' testImplementation 'org.junit.jupiter:junit-jupiter-api:5.9.2' testImplementation 'org.hamcrest:hamcrest:2.2' testRuntimeOnly 'org.junit.platform:junit-platform-launcher' @@ -51,20 +51,20 @@ test { testLogging { outputs.upToDateWhen { false } showStandardStreams = true - events "PASSED", "SKIPPED", "FAILED", "STANDARD_OUT", "STANDARD_ERROR" - exceptionFormat = "full" + events 'PASSED', 'SKIPPED', 'FAILED', 'STANDARD_OUT', 'STANDARD_ERROR' + exceptionFormat = 'full' } } jar { manifest { attributes( - "Class-Path": configurations.compileClasspath.collect { it.getName() }.join(" ") + 'Class-Path': configurations.compileClasspath.collect { it.getName() }.join(' ') ) } } shadowJar { - archiveBaseName = "fkjoins-standalone" + archiveBaseName = 'fkjoins-standalone' archiveClassifier = '' } diff --git a/hopping-windows/flinksql/build.gradle b/hopping-windows/flinksql/build.gradle index b2b95b81..c860d1b4 100644 --- a/hopping-windows/flinksql/build.gradle +++ b/hopping-windows/flinksql/build.gradle @@ -13,7 +13,7 @@ java { sourceCompatibility = JavaVersion.VERSION_17 targetCompatibility = JavaVersion.VERSION_17 } -version = "0.0.1" +version = '0.0.1' repositories { mavenCentral() diff --git a/joining-stream-stream/flinksql/build.gradle b/joining-stream-stream/flinksql/build.gradle index b2b95b81..c860d1b4 100644 --- a/joining-stream-stream/flinksql/build.gradle +++ b/joining-stream-stream/flinksql/build.gradle @@ -13,7 +13,7 @@ java { sourceCompatibility = JavaVersion.VERSION_17 targetCompatibility = JavaVersion.VERSION_17 } -version = "0.0.1" +version = '0.0.1' repositories { mavenCentral() diff --git a/joining-stream-stream/kstreams/build.gradle b/joining-stream-stream/kstreams/build.gradle index 5106d259..f47d4fdb 100644 --- a/joining-stream-stream/kstreams/build.gradle +++ b/joining-stream-stream/kstreams/build.gradle @@ -5,8 +5,8 @@ buildscript { } plugins { - id "java" - id "application" + id 'java' + id 'application' id 'com.github.johnrengelman.shadow' version '8.1.1' } @@ -16,7 +16,7 @@ java { } application { - mainClass = "io.confluent.developer.JoinStreamToStream" + mainClass = 'io.confluent.developer.JoinStreamToStream' } repositories { @@ -26,7 +26,7 @@ repositories { dependencies { implementation project(':common') - implementation "org.slf4j:slf4j-simple:2.0.7" + implementation 'org.slf4j:slf4j-simple:2.0.7' implementation 'org.apache.kafka:kafka-streams:4.0.0' implementation('org.apache.kafka:kafka-clients') { version { @@ -34,7 +34,7 @@ dependencies { } } - testImplementation "org.apache.kafka:kafka-streams-test-utils:4.0.0" + testImplementation 'org.apache.kafka:kafka-streams-test-utils:4.0.0' testImplementation 'org.junit.jupiter:junit-jupiter-api:5.9.2' testImplementation 'org.hamcrest:hamcrest:2.2' testRuntimeOnly 'org.junit.platform:junit-platform-launcher' @@ -46,8 +46,8 @@ test { testLogging { outputs.upToDateWhen { false } showStandardStreams = true - events "PASSED", "SKIPPED", "FAILED", "STANDARD_OUT", "STANDARD_ERROR" - exceptionFormat = "full" + events 'PASSED', 'SKIPPED', 'FAILED', 'STANDARD_OUT', 'STANDARD_ERROR' + exceptionFormat = 'full' } } @@ -60,6 +60,6 @@ jar { } shadowJar { - archiveBaseName = "kstreams-stream-stream-join-standalone" + archiveBaseName = 'kstreams-stream-stream-join-standalone' archiveClassifier = '' } diff --git a/joining-stream-table/kstreams/build.gradle b/joining-stream-table/kstreams/build.gradle index fe523447..89066584 100644 --- a/joining-stream-table/kstreams/build.gradle +++ b/joining-stream-table/kstreams/build.gradle @@ -5,8 +5,8 @@ buildscript { } plugins { - id "java" - id "application" + id 'java' + id 'application' id 'com.github.johnrengelman.shadow' version '8.1.1' } @@ -16,7 +16,7 @@ java { } application { - mainClass = "io.confluent.developer.JoinStreamToTable" + mainClass = 'io.confluent.developer.JoinStreamToTable' } repositories { @@ -26,7 +26,7 @@ repositories { dependencies { implementation project(':common') - implementation "org.slf4j:slf4j-simple:2.0.7" + implementation 'org.slf4j:slf4j-simple:2.0.7' implementation 'org.apache.kafka:kafka-streams:4.0.0' implementation('org.apache.kafka:kafka-clients') { version { @@ -34,7 +34,7 @@ dependencies { } } - testImplementation "org.apache.kafka:kafka-streams-test-utils:4.0.0" + testImplementation 'org.apache.kafka:kafka-streams-test-utils:4.0.0' testImplementation 'org.junit.jupiter:junit-jupiter-api:5.9.2' testImplementation 'org.hamcrest:hamcrest:2.2' testRuntimeOnly 'org.junit.platform:junit-platform-launcher' @@ -46,8 +46,8 @@ test { testLogging { outputs.upToDateWhen { false } showStandardStreams = true - events "PASSED", "SKIPPED", "FAILED", "STANDARD_OUT", "STANDARD_ERROR" - exceptionFormat = "full" + events 'PASSED', 'SKIPPED', 'FAILED', 'STANDARD_OUT', 'STANDARD_ERROR' + exceptionFormat = 'full' } } @@ -60,6 +60,6 @@ jar { } shadowJar { - archiveBaseName = "kstreams-stream-table-join-standalone" + archiveBaseName = 'kstreams-stream-table-join-standalone' archiveClassifier = '' } diff --git a/joining-table-table/kstreams/build.gradle b/joining-table-table/kstreams/build.gradle index 09d921f2..e1aab3fd 100644 --- a/joining-table-table/kstreams/build.gradle +++ b/joining-table-table/kstreams/build.gradle @@ -5,8 +5,8 @@ buildscript { } plugins { - id "java" - id "application" + id 'java' + id 'application' id 'com.github.johnrengelman.shadow' version '8.1.1' } @@ -16,7 +16,7 @@ java { } application { - mainClass = "io.confluent.developer.JoinTableToTable" + mainClass = 'io.confluent.developer.JoinTableToTable' } repositories { @@ -26,7 +26,7 @@ repositories { dependencies { implementation project(':common') - implementation "org.slf4j:slf4j-simple:2.0.7" + implementation 'org.slf4j:slf4j-simple:2.0.7' implementation 'org.apache.kafka:kafka-streams:4.0.0' implementation('org.apache.kafka:kafka-clients') { version { @@ -34,7 +34,7 @@ dependencies { } } - testImplementation "org.apache.kafka:kafka-streams-test-utils:4.0.0" + testImplementation 'org.apache.kafka:kafka-streams-test-utils:4.0.0' testImplementation 'org.junit.jupiter:junit-jupiter-api:5.9.2' testImplementation 'org.hamcrest:hamcrest:2.2' testRuntimeOnly 'org.junit.platform:junit-platform-launcher' @@ -46,8 +46,8 @@ test { testLogging { outputs.upToDateWhen { false } showStandardStreams = true - events "PASSED", "SKIPPED", "FAILED", "STANDARD_OUT", "STANDARD_ERROR" - exceptionFormat = "full" + events 'PASSED', 'SKIPPED', 'FAILED', 'STANDARD_OUT', 'STANDARD_ERROR' + exceptionFormat = 'full' } } @@ -60,6 +60,6 @@ jar { } shadowJar { - archiveBaseName = "kstreams-table-table-standalone" + archiveBaseName = 'kstreams-table-table-standalone' archiveClassifier = '' } diff --git a/kafka-consumer-application/kafka/build.gradle b/kafka-consumer-application/kafka/build.gradle index 5e22f180..b710cfb1 100644 --- a/kafka-consumer-application/kafka/build.gradle +++ b/kafka-consumer-application/kafka/build.gradle @@ -5,9 +5,9 @@ buildscript { } plugins { - id "java" - id "idea" - id "eclipse" + id 'java' + id 'idea' + id 'eclipse' id 'com.github.johnrengelman.shadow' version '8.1.1' id 'application' } @@ -18,7 +18,7 @@ java { } application { - mainClass = "io.confluent.developer.KafkaConsumerApplication" + mainClass = 'io.confluent.developer.KafkaConsumerApplication' } @@ -26,7 +26,7 @@ repositories { mavenCentral() maven { - url "https://packages.confluent.io/maven" + url 'https://packages.confluent.io/maven' } } @@ -46,19 +46,19 @@ test { testLogging { outputs.upToDateWhen { false } showStandardStreams = true - exceptionFormat = "full" + exceptionFormat = 'full' } } jar { manifest { attributes( - "Class-Path": configurations.compileClasspath.collect { it.getName() }.join(" ") + 'Class-Path': configurations.compileClasspath.collect { it.getName() }.join(' ') ) } } shadowJar { - archiveBaseName = "kafka-consumer-application-standalone" + archiveBaseName = 'kafka-consumer-application-standalone' archiveClassifier = '' } diff --git a/kafka-native-testcontainers/kafka/build.gradle b/kafka-native-testcontainers/kafka/build.gradle index 7ff9170f..f265d759 100644 --- a/kafka-native-testcontainers/kafka/build.gradle +++ b/kafka-native-testcontainers/kafka/build.gradle @@ -5,9 +5,9 @@ buildscript { } plugins { - id "java" - id "idea" - id "eclipse" + id 'java' + id 'idea' + id 'eclipse' id 'com.github.johnrengelman.shadow' version '8.1.1' id 'application' } @@ -18,7 +18,7 @@ java { } application { - mainClass = "io.confluent.developer.KafkaPrimalityRouter" + mainClass = 'io.confluent.developer.KafkaPrimalityRouter' } @@ -26,7 +26,7 @@ repositories { mavenCentral() maven { - url "https://packages.confluent.io/maven" + url 'https://packages.confluent.io/maven' } } @@ -50,19 +50,19 @@ test { testLogging { outputs.upToDateWhen { false } showStandardStreams = true - exceptionFormat = "full" + exceptionFormat = 'full' } } jar { manifest { attributes( - "Class-Path": configurations.compileClasspath.collect { it.getName() }.join(" ") + 'Class-Path': configurations.compileClasspath.collect { it.getName() }.join(' ') ) } } shadowJar { - archiveBaseName = "kafka-native-testcontainers-standalone" + archiveBaseName = 'kafka-native-testcontainers-standalone' archiveClassifier = '' } diff --git a/kafka-producer-application/kafka/build.gradle b/kafka-producer-application/kafka/build.gradle index 612c5974..36b33d04 100644 --- a/kafka-producer-application/kafka/build.gradle +++ b/kafka-producer-application/kafka/build.gradle @@ -5,10 +5,10 @@ buildscript { } plugins { - id "java" - id "application" - id "idea" - id "eclipse" + id 'java' + id 'application' + id 'idea' + id 'eclipse' id 'com.github.johnrengelman.shadow' version '8.1.1' } @@ -18,21 +18,21 @@ java { } application { - mainClass = "io.confluent.developer.KafkaProducerApplication" + mainClass = 'io.confluent.developer.KafkaProducerApplication' } repositories { mavenCentral() maven { - url "https://packages.confluent.io/maven" + url 'https://packages.confluent.io/maven' } } dependencies { - implementation project(":common") - implementation "org.slf4j:slf4j-simple:2.0.7" - implementation "org.apache.kafka:kafka-clients:4.0.0" + implementation project(':common') + implementation 'org.slf4j:slf4j-simple:2.0.7' + implementation 'org.apache.kafka:kafka-clients:4.0.0' testImplementation 'com.google.guava:guava:31.1-jre' testImplementation 'org.junit.jupiter:junit-jupiter-api:5.9.2' testRuntimeOnly 'org.junit.platform:junit-platform-launcher' @@ -46,19 +46,19 @@ test { testLogging { outputs.upToDateWhen { false } showStandardStreams = true - exceptionFormat = "full" + exceptionFormat = 'full' } } jar { manifest { attributes( - "Class-Path": configurations.compileClasspath.collect { it.getName() }.join(" ") + 'Class-Path': configurations.compileClasspath.collect { it.getName() }.join(' ') ) } } shadowJar { - archiveBaseName = "kafka-producer-application-standalone" + archiveBaseName = 'kafka-producer-application-standalone' archiveClassifier = '' } diff --git a/kafka-streams-schedule-operations/kstreams/build.gradle b/kafka-streams-schedule-operations/kstreams/build.gradle index 11a7a401..ddb28d5d 100644 --- a/kafka-streams-schedule-operations/kstreams/build.gradle +++ b/kafka-streams-schedule-operations/kstreams/build.gradle @@ -5,8 +5,8 @@ buildscript { } plugins { - id "java" - id "application" + id 'java' + id 'application' id 'com.github.johnrengelman.shadow' version '8.1.1' } @@ -16,20 +16,20 @@ java { } application { - mainClass = "io.confluent.developer.KafkaStreamsPunctuation" + mainClass = 'io.confluent.developer.KafkaStreamsPunctuation' } repositories { mavenCentral() maven { - url "https://packages.confluent.io/maven" + url 'https://packages.confluent.io/maven' } } dependencies { implementation project(':common') - implementation "org.slf4j:slf4j-simple:2.0.7" + implementation 'org.slf4j:slf4j-simple:2.0.7' implementation 'org.apache.kafka:kafka-streams:4.0.0' implementation('org.apache.kafka:kafka-clients') { version { @@ -37,7 +37,7 @@ dependencies { } } - testImplementation "org.apache.kafka:kafka-streams-test-utils:4.0.0" + testImplementation 'org.apache.kafka:kafka-streams-test-utils:4.0.0' testImplementation 'org.junit.jupiter:junit-jupiter-api:5.9.2' testImplementation 'org.hamcrest:hamcrest:2.2' testRuntimeOnly 'org.junit.platform:junit-platform-launcher' @@ -49,8 +49,8 @@ test { testLogging { outputs.upToDateWhen { false } showStandardStreams = true - events "PASSED", "SKIPPED", "FAILED", "STANDARD_OUT", "STANDARD_ERROR" - exceptionFormat = "full" + events 'PASSED', 'SKIPPED', 'FAILED', 'STANDARD_OUT', 'STANDARD_ERROR' + exceptionFormat = 'full' } } @@ -58,12 +58,12 @@ test { jar { manifest { attributes( - "Class-Path": configurations.compileClasspath.collect { it.getName() }.join(" ") + 'Class-Path': configurations.compileClasspath.collect { it.getName() }.join(' ') ) } } shadowJar { - archiveBaseName = "kafka-streams-schedule-operations-standalone" + archiveBaseName = 'kafka-streams-schedule-operations-standalone' archiveClassifier = '' } diff --git a/lagging-events/flinksql/build.gradle b/lagging-events/flinksql/build.gradle index b2b95b81..c860d1b4 100644 --- a/lagging-events/flinksql/build.gradle +++ b/lagging-events/flinksql/build.gradle @@ -13,7 +13,7 @@ java { sourceCompatibility = JavaVersion.VERSION_17 targetCompatibility = JavaVersion.VERSION_17 } -version = "0.0.1" +version = '0.0.1' repositories { mavenCentral() diff --git a/merging/flinksql/build.gradle b/merging/flinksql/build.gradle index b2b95b81..c860d1b4 100644 --- a/merging/flinksql/build.gradle +++ b/merging/flinksql/build.gradle @@ -13,7 +13,7 @@ java { sourceCompatibility = JavaVersion.VERSION_17 targetCompatibility = JavaVersion.VERSION_17 } -version = "0.0.1" +version = '0.0.1' repositories { mavenCentral() diff --git a/merging/kstreams/build.gradle b/merging/kstreams/build.gradle index 2c319d4a..ff329032 100644 --- a/merging/kstreams/build.gradle +++ b/merging/kstreams/build.gradle @@ -5,8 +5,8 @@ buildscript { } plugins { - id "java" - id "application" + id 'java' + id 'application' id 'com.github.johnrengelman.shadow' version '8.1.1' } @@ -16,20 +16,20 @@ java { } application { - mainClass = "io.confluent.developer.MergeStreams" + mainClass = 'io.confluent.developer.MergeStreams' } repositories { mavenCentral() maven { - url "https://packages.confluent.io/maven" + url 'https://packages.confluent.io/maven' } } dependencies { implementation project(':common') - implementation "org.slf4j:slf4j-simple:2.0.7" + implementation 'org.slf4j:slf4j-simple:2.0.7' implementation 'org.apache.kafka:kafka-streams:4.0.0' implementation('org.apache.kafka:kafka-clients') { version { @@ -37,7 +37,7 @@ dependencies { } } - testImplementation "org.apache.kafka:kafka-streams-test-utils:4.0.0" + testImplementation 'org.apache.kafka:kafka-streams-test-utils:4.0.0' testImplementation 'org.junit.jupiter:junit-jupiter-api:5.9.2' testImplementation 'org.hamcrest:hamcrest:2.2' testRuntimeOnly 'org.junit.platform:junit-platform-launcher' @@ -49,8 +49,8 @@ test { testLogging { outputs.upToDateWhen { false } showStandardStreams = true - events "PASSED", "SKIPPED", "FAILED", "STANDARD_OUT", "STANDARD_ERROR" - exceptionFormat = "full" + events 'PASSED', 'SKIPPED', 'FAILED', 'STANDARD_OUT', 'STANDARD_ERROR' + exceptionFormat = 'full' } } @@ -58,12 +58,12 @@ test { jar { manifest { attributes( - "Class-Path": configurations.compileClasspath.collect { it.getName() }.join(" ") + 'Class-Path': configurations.compileClasspath.collect { it.getName() }.join(' ') ) } } shadowJar { - archiveBaseName = "kstreams-merge-standalone" + archiveBaseName = 'kstreams-merge-standalone' archiveClassifier = '' } diff --git a/multi-joins/flinksql/build.gradle b/multi-joins/flinksql/build.gradle index b2b95b81..c860d1b4 100644 --- a/multi-joins/flinksql/build.gradle +++ b/multi-joins/flinksql/build.gradle @@ -13,7 +13,7 @@ java { sourceCompatibility = JavaVersion.VERSION_17 targetCompatibility = JavaVersion.VERSION_17 } -version = "0.0.1" +version = '0.0.1' repositories { mavenCentral() diff --git a/multiple-event-types-avro/kafka/build.gradle b/multiple-event-types-avro/kafka/build.gradle index 3931b1cb..b946526e 100644 --- a/multiple-event-types-avro/kafka/build.gradle +++ b/multiple-event-types-avro/kafka/build.gradle @@ -3,44 +3,44 @@ buildscript { mavenCentral() gradlePluginPortal() maven { - url = "https://packages.confluent.io/maven/" + url = 'https://packages.confluent.io/maven/' } maven { - url = "https://jitpack.io" + url = 'https://jitpack.io' } } dependencies { - classpath "gradle.plugin.com.github.jengelman.gradle.plugins:shadow:7.0.0" + classpath 'gradle.plugin.com.github.jengelman.gradle.plugins:shadow:7.0.0' } } plugins { - id "java" - id "com.google.cloud.tools.jib" version "3.3.1" - id "idea" - id "eclipse" - id "com.github.imflog.kafka-schema-registry-gradle-plugin" version "1.13.0" - id "com.github.davidmc24.gradle.plugin.avro" version "1.9.1" + id 'java' + id 'com.google.cloud.tools.jib' version '3.3.1' + id 'idea' + id 'eclipse' + id 'com.github.imflog.kafka-schema-registry-gradle-plugin' version '1.13.0' + id 'com.github.davidmc24.gradle.plugin.avro' version '1.9.1' } java { sourceCompatibility = JavaVersion.VERSION_17 targetCompatibility = JavaVersion.VERSION_17 } -version = "0.0.1" +version = '0.0.1' repositories { mavenCentral() maven { - url "https://packages.confluent.io/maven" + url 'https://packages.confluent.io/maven' } } -apply plugin: "com.github.johnrengelman.shadow" +apply plugin: 'com.github.johnrengelman.shadow' dependencies { - implementation "org.slf4j:slf4j-simple:2.0.7" + implementation 'org.slf4j:slf4j-simple:2.0.7' implementation('org.apache.kafka:kafka-clients') { version { strictly '4.0.0' @@ -48,7 +48,7 @@ dependencies { } implementation 'org.apache.kafka:kafka-streams:4.0.0' implementation 'org.apache.avro:avro:1.11.1' - implementation "io.confluent:kafka-avro-serializer:7.5.1" + implementation 'io.confluent:kafka-avro-serializer:7.5.1' testImplementation 'com.google.guava:guava:31.1-jre' testImplementation 'org.junit.jupiter:junit-jupiter-api:5.9.2' testRuntimeOnly 'org.junit.platform:junit-platform-launcher' @@ -62,32 +62,32 @@ test { testLogging { outputs.upToDateWhen { false } showStandardStreams = true - exceptionFormat = "full" + exceptionFormat = 'full' } } jar { manifest { attributes( - "Class-Path": configurations.compileClasspath.collect { it.getName() }.join(" "), - "Main-Class": "io.confluent.developer.MultiEventAvroProduceConsumeApp" + 'Class-Path': configurations.compileClasspath.collect { it.getName() }.join(' '), + 'Main-Class': 'io.confluent.developer.MultiEventAvroProduceConsumeApp' ) } } shadowJar { - archiveBaseName = "multiple-event-types-avro-standalone" + archiveBaseName = 'multiple-event-types-avro-standalone' archiveClassifier = '' } schemaRegistry { def props = new Properties() - def configs = file("cloud.properties") + def configs = file('cloud.properties') if (configs.exists()) { configs.withInputStream { props.load(it) } - def srUrl = props.getProperty("schema.registry.url") - def auth = props.getProperty("basic.auth.user.info").split(":") - println "Using Confluent properties Schema Registry endpoint:${srUrl}, username:${auth[0]},password:${auth[1]}" + def srUrl = props.getProperty('schema.registry.url') + def auth = props.getProperty('basic.auth.user.info').split(':') + println 'Using Confluent properties Schema Registry endpoint:${srUrl}, username:${auth[0]},password:${auth[1]}' url = srUrl @@ -97,23 +97,23 @@ schemaRegistry { // password is everything after ':' in the basic.auth.user.info property password = auth[1] } - } else if (file("local.properties").exists()) { - configs = file("local.properties") + } else if (file('local.properties').exists()) { + configs = file('local.properties') configs.withInputStream { props.load(it) } - def srUrl = props.getProperty("schema.registry.url") - println "Using local dev properties Schema Registry endpoint:${srUrl}" + def srUrl = props.getProperty('schema.registry.url') + println 'Using local dev properties Schema Registry endpoint:${srUrl}' } else { - println "No configs to parse yet" + println 'No configs to parse yet' } - // Possible types are ["JSON", "PROTOBUF", "AVRO"] + // Possible types are ['JSON', 'PROTOBUF', 'AVRO'] register { // paths relative to top level subject('pageview', 'multiple-event-types-avro/kafka/src/main/avro/pageview.avsc', 'AVRO') subject('purchase', 'multiple-event-types-avro/kafka/src/main/avro/purchase.avsc', 'AVRO') subject('avro-events-value', 'multiple-event-types-avro/kafka/src/main/avro/all-events.avsc', 'AVRO') - .addReference("io.confluent.developer.avro.Pageview", "pageview", 1) - .addReference("io.confluent.developer.avro.Purchase", "purchase", 1) + .addReference('io.confluent.developer.avro.Pageview', 'pageview', 1) + .addReference('io.confluent.developer.avro.Purchase', 'purchase', 1) } } diff --git a/multiple-event-types-protobuf/kafka/build.gradle b/multiple-event-types-protobuf/kafka/build.gradle index ecbb5400..2cb70ccc 100644 --- a/multiple-event-types-protobuf/kafka/build.gradle +++ b/multiple-event-types-protobuf/kafka/build.gradle @@ -3,44 +3,44 @@ buildscript { mavenCentral() gradlePluginPortal() maven { - url = "https://packages.confluent.io/maven/" + url = 'https://packages.confluent.io/maven/' } maven { - url = "https://jitpack.io" + url = 'https://jitpack.io' } } dependencies { - classpath "gradle.plugin.com.github.jengelman.gradle.plugins:shadow:7.0.0" + classpath 'gradle.plugin.com.github.jengelman.gradle.plugins:shadow:7.0.0' } } plugins { - id "java" - id "com.google.cloud.tools.jib" version "3.3.1" - id "idea" - id "eclipse" - id "com.github.imflog.kafka-schema-registry-gradle-plugin" version "1.13.0" - id "com.google.protobuf" version "0.9.2" + id 'java' + id 'com.google.cloud.tools.jib' version '3.3.1' + id 'idea' + id 'eclipse' + id 'com.github.imflog.kafka-schema-registry-gradle-plugin' version '1.13.0' + id 'com.google.protobuf' version '0.9.2' } java { sourceCompatibility = JavaVersion.VERSION_17 targetCompatibility = JavaVersion.VERSION_17 } -version = "0.0.1" +version = '0.0.1' repositories { mavenCentral() maven { - url "https://packages.confluent.io/maven" + url 'https://packages.confluent.io/maven' } } -apply plugin: "com.github.johnrengelman.shadow" +apply plugin: 'com.github.johnrengelman.shadow' dependencies { - implementation "org.slf4j:slf4j-simple:2.0.7" + implementation 'org.slf4j:slf4j-simple:2.0.7' implementation('org.apache.kafka:kafka-clients') { version { strictly '4.0.0' @@ -48,8 +48,8 @@ dependencies { } implementation 'org.apache.kafka:kafka-streams:4.0.0' implementation 'com.google.protobuf:protobuf-java:3.22.2' - implementation "io.confluent:kafka-protobuf-serializer:7.5.1" - implementation "io.confluent:kafka-protobuf-provider:7.5.1" + implementation 'io.confluent:kafka-protobuf-serializer:7.5.1' + implementation 'io.confluent:kafka-protobuf-provider:7.5.1' testImplementation 'com.google.guava:guava:31.1-jre' testImplementation 'org.junit.jupiter:junit-jupiter-api:5.9.2' testRuntimeOnly 'org.junit.platform:junit-platform-launcher' @@ -59,7 +59,7 @@ dependencies { } protobuf { - generatedFilesBaseDir = "${project.buildDir}/generated-main-proto-java" + generatedFilesBaseDir = '${project.buildDir}/generated-main-proto-java' protoc { artifact = 'com.google.protobuf:protoc:3.22.2' @@ -71,20 +71,20 @@ test { testLogging { outputs.upToDateWhen { false } showStandardStreams = true - exceptionFormat = "full" + exceptionFormat = 'full' } } jar { manifest { attributes( - "Class-Path": configurations.compileClasspath.collect { it.getName() }.join(" "), - "Main-Class": "io.confluent.developer.MultiEventProtobufProduceConsumeApp" + 'Class-Path': configurations.compileClasspath.collect { it.getName() }.join(' '), + 'Main-Class': 'io.confluent.developer.MultiEventProtobufProduceConsumeApp' ) } } shadowJar { - archiveBaseName = "multiple-event-types-protobuf-standalone" + archiveBaseName = 'multiple-event-types-protobuf-standalone' archiveClassifier = '' } diff --git a/naming-changelog-repartition-topics/kstreams/build.gradle b/naming-changelog-repartition-topics/kstreams/build.gradle index fab54c4e..b437b251 100644 --- a/naming-changelog-repartition-topics/kstreams/build.gradle +++ b/naming-changelog-repartition-topics/kstreams/build.gradle @@ -13,8 +13,8 @@ buildscript { } plugins { - id "java" - id "application" + id 'java' + id 'application' id 'com.github.johnrengelman.shadow' version '8.1.1' } @@ -24,7 +24,7 @@ java { } application { - mainClass = "io.confluent.developer.NamingChangelogAndRepartitionTopics" + mainClass = 'io.confluent.developer.NamingChangelogAndRepartitionTopics' } repositories { @@ -35,17 +35,17 @@ repositories { dependencies { implementation project(':common') - implementation "org.slf4j:slf4j-simple:2.0.7" + implementation 'org.slf4j:slf4j-simple:2.0.7' implementation 'org.apache.kafka:kafka-streams:4.0.0' implementation('org.apache.kafka:kafka-clients') { version { strictly '4.0.0' } } - implementation "io.confluent:kafka-streams-avro-serde:7.5.1" - implementation "com.typesafe:config:1.4.2" + implementation 'io.confluent:kafka-streams-avro-serde:7.5.1' + implementation 'com.typesafe:config:1.4.2' - testImplementation "org.apache.kafka:kafka-streams-test-utils:4.0.0" + testImplementation 'org.apache.kafka:kafka-streams-test-utils:4.0.0' testImplementation 'org.junit.jupiter:junit-jupiter-api:5.9.2' testImplementation 'org.hamcrest:hamcrest:2.2' testRuntimeOnly 'org.junit.platform:junit-platform-launcher' @@ -57,20 +57,20 @@ test { testLogging { outputs.upToDateWhen { false } showStandardStreams = true - events "PASSED", "SKIPPED", "FAILED", "STANDARD_OUT", "STANDARD_ERROR" - exceptionFormat = "full" + events 'PASSED', 'SKIPPED', 'FAILED', 'STANDARD_OUT', 'STANDARD_ERROR' + exceptionFormat = 'full' } } jar { manifest { attributes( - "Class-Path": configurations.runtimeClasspath.collect { it.getName() }.join(" ") + 'Class-Path': configurations.runtimeClasspath.collect { it.getName() }.join(' ') ) } } shadowJar { - archiveBaseName = "naming-stateful-operations-standalone" + archiveBaseName = 'naming-stateful-operations-standalone' archiveClassifier = '' } diff --git a/over-aggregations/flinksql/build.gradle b/over-aggregations/flinksql/build.gradle index 15d9a151..564c2466 100644 --- a/over-aggregations/flinksql/build.gradle +++ b/over-aggregations/flinksql/build.gradle @@ -13,7 +13,7 @@ java { sourceCompatibility = JavaVersion.VERSION_17 targetCompatibility = JavaVersion.VERSION_17 } -version = "0.0.1" +version = '0.0.1' repositories { mavenCentral() diff --git a/pattern-matching/flinksql/build.gradle b/pattern-matching/flinksql/build.gradle index b2b95b81..c860d1b4 100644 --- a/pattern-matching/flinksql/build.gradle +++ b/pattern-matching/flinksql/build.gradle @@ -13,7 +13,7 @@ java { sourceCompatibility = JavaVersion.VERSION_17 targetCompatibility = JavaVersion.VERSION_17 } -version = "0.0.1" +version = '0.0.1' repositories { mavenCentral() diff --git a/reordering-streams/kstreams/build.gradle b/reordering-streams/kstreams/build.gradle index c0bf8ca4..f4144a74 100644 --- a/reordering-streams/kstreams/build.gradle +++ b/reordering-streams/kstreams/build.gradle @@ -5,8 +5,8 @@ buildscript { } plugins { - id "java" - id "application" + id 'java' + id 'application' id 'com.github.johnrengelman.shadow' version '8.1.1' } @@ -16,20 +16,20 @@ java { } application { - mainClass = "io.confluent.developer.ReorderStreams" + mainClass = 'io.confluent.developer.ReorderStreams' } repositories { mavenCentral() maven { - url "https://packages.confluent.io/maven" + url 'https://packages.confluent.io/maven' } } dependencies { implementation project(':common') - implementation "org.slf4j:slf4j-simple:2.0.7" + implementation 'org.slf4j:slf4j-simple:2.0.7' implementation 'org.apache.kafka:kafka-streams:4.0.0' implementation 'org.apache.kafka:kafka-clients:4.0.0' @@ -45,8 +45,8 @@ test { testLogging { outputs.upToDateWhen { false } showStandardStreams = true - events "PASSED", "SKIPPED", "FAILED", "STANDARD_OUT", "STANDARD_ERROR" - exceptionFormat = "full" + events 'PASSED', 'SKIPPED', 'FAILED', 'STANDARD_OUT', 'STANDARD_ERROR' + exceptionFormat = 'full' } } @@ -54,12 +54,12 @@ test { jar { manifest { attributes( - "Class-Path": configurations.compileClasspath.collect { it.getName() }.join(" ") + 'Class-Path': configurations.compileClasspath.collect { it.getName() }.join(' ') ) } } shadowJar { - archiveBaseName = "reorder-streams" + archiveBaseName = 'reorder-streams' archiveClassifier = '' } diff --git a/schedule-ktable-ttl-aggregate/kstreams/build.gradle b/schedule-ktable-ttl-aggregate/kstreams/build.gradle index 0d663edb..3e60ebc6 100644 --- a/schedule-ktable-ttl-aggregate/kstreams/build.gradle +++ b/schedule-ktable-ttl-aggregate/kstreams/build.gradle @@ -5,8 +5,8 @@ buildscript { } plugins { - id "java" - id "application" + id 'java' + id 'application' id 'com.github.johnrengelman.shadow' version '8.1.1' } @@ -16,7 +16,7 @@ java { } application { - mainClass = "io.confluent.developer.KTableTTLAggregate" + mainClass = 'io.confluent.developer.KTableTTLAggregate' } repositories { @@ -26,17 +26,17 @@ repositories { dependencies { implementation project(':common') - implementation "org.slf4j:slf4j-simple:2.0.7" - implementation "io.confluent:common-utils:7.3.3" + implementation 'org.slf4j:slf4j-simple:2.0.7' + implementation 'io.confluent:common-utils:7.3.3' implementation 'org.apache.kafka:kafka-streams:4.0.0' implementation('org.apache.kafka:kafka-clients') { version { strictly '4.0.0' } } - implementation "com.typesafe:config:1.4.2" + implementation 'com.typesafe:config:1.4.2' - testImplementation "org.apache.kafka:kafka-streams-test-utils:4.0.0" + testImplementation 'org.apache.kafka:kafka-streams-test-utils:4.0.0' testImplementation 'org.junit.jupiter:junit-jupiter-api:5.9.2' testImplementation 'org.hamcrest:hamcrest:2.2' testRuntimeOnly 'org.junit.platform:junit-platform-launcher' @@ -48,20 +48,20 @@ test { testLogging { outputs.upToDateWhen { false } showStandardStreams = true - events "PASSED", "SKIPPED", "FAILED", "STANDARD_OUT", "STANDARD_ERROR" - exceptionFormat = "full" + events 'PASSED', 'SKIPPED', 'FAILED', 'STANDARD_OUT', 'STANDARD_ERROR' + exceptionFormat = 'full' } } jar { manifest { attributes( - "Class-Path": configurations.runtimeClasspath.collect { it.getName() }.join(" ") + 'Class-Path': configurations.runtimeClasspath.collect { it.getName() }.join(' ') ) } } shadowJar { - archiveBaseName = "ktable-ttl-aggregate-standalone" + archiveBaseName = 'ktable-ttl-aggregate-standalone' archiveClassifier = '' } diff --git a/schedule-ktable-ttl/kstreams/build.gradle b/schedule-ktable-ttl/kstreams/build.gradle index c6b150d3..630b441c 100644 --- a/schedule-ktable-ttl/kstreams/build.gradle +++ b/schedule-ktable-ttl/kstreams/build.gradle @@ -5,8 +5,8 @@ buildscript { } plugins { - id "java" - id "application" + id 'java' + id 'application' id 'com.github.johnrengelman.shadow' version '8.1.1' } @@ -16,7 +16,7 @@ java { } application { - mainClass = "io.confluent.developer.KTableTTL" + mainClass = 'io.confluent.developer.KTableTTL' } repositories { @@ -26,17 +26,17 @@ repositories { dependencies { implementation project(':common') - implementation "org.slf4j:slf4j-simple:2.0.7" - implementation "io.confluent:common-utils:7.3.3" + implementation 'org.slf4j:slf4j-simple:2.0.7' + implementation 'io.confluent:common-utils:7.3.3' implementation 'org.apache.kafka:kafka-streams:4.0.0' implementation('org.apache.kafka:kafka-clients') { version { strictly '4.0.0' } } - implementation "com.typesafe:config:1.4.2" + implementation 'com.typesafe:config:1.4.2' - testImplementation "org.apache.kafka:kafka-streams-test-utils:4.0.0" + testImplementation 'org.apache.kafka:kafka-streams-test-utils:4.0.0' testImplementation 'org.junit.jupiter:junit-jupiter-api:5.9.2' testImplementation 'org.hamcrest:hamcrest:2.2' testRuntimeOnly 'org.junit.platform:junit-platform-launcher' @@ -48,20 +48,20 @@ test { testLogging { outputs.upToDateWhen { false } showStandardStreams = true - events "PASSED", "SKIPPED", "FAILED", "STANDARD_OUT", "STANDARD_ERROR" - exceptionFormat = "full" + events 'PASSED', 'SKIPPED', 'FAILED', 'STANDARD_OUT', 'STANDARD_ERROR' + exceptionFormat = 'full' } } jar { manifest { attributes( - "Class-Path": configurations.runtimeClasspath.collect { it.getName() }.join(" ") + 'Class-Path': configurations.runtimeClasspath.collect { it.getName() }.join(' ') ) } } shadowJar { - archiveBaseName = "ktable-ttl-standalone" + archiveBaseName = 'ktable-ttl-standalone' archiveClassifier = '' } diff --git a/serialization/kstreams/build.gradle b/serialization/kstreams/build.gradle index b7875c39..ccee065d 100644 --- a/serialization/kstreams/build.gradle +++ b/serialization/kstreams/build.gradle @@ -5,11 +5,11 @@ buildscript { } plugins { - id "java" - id "application" + id 'java' + id 'application' id 'com.github.johnrengelman.shadow' version '8.1.1' - id "com.google.protobuf" version "0.9.2" - id "com.github.davidmc24.gradle.plugin.avro" version "1.7.0" + id 'com.google.protobuf' version '0.9.2' + id 'com.github.davidmc24.gradle.plugin.avro' version '1.7.0' } java { @@ -18,7 +18,7 @@ java { } application { - mainClass = "io.confluent.developer.AvroToProtobuf" + mainClass = 'io.confluent.developer.AvroToProtobuf' } repositories { mavenCentral() @@ -26,9 +26,9 @@ repositories { } dependencies { implementation project(':common') - implementation "org.slf4j:slf4j-simple:2.0.7" - implementation "org.apache.avro:avro:1.11.1" - implementation "com.google.protobuf:protobuf-java:4.30.0" + implementation 'org.slf4j:slf4j-simple:2.0.7' + implementation 'org.apache.avro:avro:1.11.1' + implementation 'com.google.protobuf:protobuf-java:4.30.0' implementation 'org.apache.kafka:kafka-streams:4.0.0' implementation('io.confluent:kafka-streams-protobuf-serde:8.0.0-463') implementation('io.confluent:kafka-streams-avro-serde:8.0.0-463') @@ -37,9 +37,9 @@ dependencies { strictly '4.0.0' } } - implementation "com.typesafe:config:1.4.2" + implementation 'com.typesafe:config:1.4.2' - testImplementation "org.apache.kafka:kafka-streams-test-utils:4.0.0" + testImplementation 'org.apache.kafka:kafka-streams-test-utils:4.0.0' testImplementation 'org.junit.jupiter:junit-jupiter-api:5.9.2' testImplementation 'org.hamcrest:hamcrest:2.2' testRuntimeOnly 'org.junit.platform:junit-platform-launcher' @@ -51,26 +51,26 @@ test { testLogging { outputs.upToDateWhen { false } showStandardStreams = true - events "PASSED", "SKIPPED", "FAILED", "STANDARD_OUT", "STANDARD_ERROR" - exceptionFormat = "full" + events 'PASSED', 'SKIPPED', 'FAILED', 'STANDARD_OUT', 'STANDARD_ERROR' + exceptionFormat = 'full' } } jar { manifest { attributes( - "Class-Path": configurations.compileClasspath.collect { it.getName() }.join(" "), + 'Class-Path': configurations.compileClasspath.collect { it.getName() }.join(' '), ) } } shadowJar { - archiveBaseName = "serialization-standalone" + archiveBaseName = 'serialization-standalone' archiveClassifier = '' } protobuf { protoc { - artifact = "com.google.protobuf:protoc:4.30.0" + artifact = 'com.google.protobuf:protoc:4.30.0' } } diff --git a/session-windows/flinksql/build.gradle b/session-windows/flinksql/build.gradle index 15d9a151..564c2466 100644 --- a/session-windows/flinksql/build.gradle +++ b/session-windows/flinksql/build.gradle @@ -13,7 +13,7 @@ java { sourceCompatibility = JavaVersion.VERSION_17 targetCompatibility = JavaVersion.VERSION_17 } -version = "0.0.1" +version = '0.0.1' repositories { mavenCentral() diff --git a/session-windows/kstreams/build.gradle b/session-windows/kstreams/build.gradle index 82a55603..58b6100e 100644 --- a/session-windows/kstreams/build.gradle +++ b/session-windows/kstreams/build.gradle @@ -13,8 +13,8 @@ buildscript { } plugins { - id "java" - id "application" + id 'java' + id 'application' id 'com.github.johnrengelman.shadow' version '8.1.1' } @@ -24,7 +24,7 @@ java { } application { - mainClass = "io.confluent.developer.SessionWindow" + mainClass = 'io.confluent.developer.SessionWindow' } repositories { @@ -35,17 +35,17 @@ repositories { dependencies { implementation project(':common') - implementation "org.slf4j:slf4j-simple:2.0.7" + implementation 'org.slf4j:slf4j-simple:2.0.7' implementation 'org.apache.kafka:kafka-streams:4.0.0' implementation('org.apache.kafka:kafka-clients') { version { strictly '4.0.0' } } - implementation "io.confluent:kafka-streams-avro-serde:7.5.1" - implementation "com.typesafe:config:1.4.2" + implementation 'io.confluent:kafka-streams-avro-serde:7.5.1' + implementation 'com.typesafe:config:1.4.2' - testImplementation "org.apache.kafka:kafka-streams-test-utils:4.0.0" + testImplementation 'org.apache.kafka:kafka-streams-test-utils:4.0.0' testImplementation 'org.junit.jupiter:junit-jupiter-api:5.9.2' testImplementation 'org.hamcrest:hamcrest:2.2' testRuntimeOnly 'org.junit.platform:junit-platform-launcher' @@ -57,20 +57,20 @@ test { testLogging { outputs.upToDateWhen { false } showStandardStreams = true - events "PASSED", "SKIPPED", "FAILED", "STANDARD_OUT", "STANDARD_ERROR" - exceptionFormat = "full" + events 'PASSED', 'SKIPPED', 'FAILED', 'STANDARD_OUT', 'STANDARD_ERROR' + exceptionFormat = 'full' } } jar { manifest { attributes( - "Class-Path": configurations.runtimeClasspath.collect { it.getName() }.join(" ") + 'Class-Path': configurations.runtimeClasspath.collect { it.getName() }.join(' ') ) } } shadowJar { - archiveBaseName = "session-windows-standalone" + archiveBaseName = 'session-windows-standalone' archiveClassifier = '' } diff --git a/sliding-windows/kstreams/build.gradle b/sliding-windows/kstreams/build.gradle index ae4393c7..8ef30ce1 100644 --- a/sliding-windows/kstreams/build.gradle +++ b/sliding-windows/kstreams/build.gradle @@ -13,8 +13,8 @@ buildscript { } plugins { - id "java" - id "application" + id 'java' + id 'application' id 'com.github.johnrengelman.shadow' version '8.1.1' } @@ -24,7 +24,7 @@ java { } application { - mainClass = "io.confluent.developer.TumblingWindow" + mainClass = 'io.confluent.developer.TumblingWindow' } repositories { @@ -35,17 +35,17 @@ repositories { dependencies { implementation project(':common') - implementation "org.slf4j:slf4j-simple:2.0.7" + implementation 'org.slf4j:slf4j-simple:2.0.7' implementation 'org.apache.kafka:kafka-streams:4.0.0' implementation('org.apache.kafka:kafka-clients') { version { strictly '4.0.0' } } - implementation "io.confluent:kafka-streams-avro-serde:7.5.1" - implementation "com.typesafe:config:1.4.2" + implementation 'io.confluent:kafka-streams-avro-serde:7.5.1' + implementation 'com.typesafe:config:1.4.2' - testImplementation "org.apache.kafka:kafka-streams-test-utils:4.0.0" + testImplementation 'org.apache.kafka:kafka-streams-test-utils:4.0.0' testImplementation 'org.junit.jupiter:junit-jupiter-api:5.9.2' testImplementation 'org.hamcrest:hamcrest:2.2' testRuntimeOnly 'org.junit.platform:junit-platform-launcher' @@ -57,20 +57,20 @@ test { testLogging { outputs.upToDateWhen { false } showStandardStreams = true - events "PASSED", "SKIPPED", "FAILED", "STANDARD_OUT", "STANDARD_ERROR" - exceptionFormat = "full" + events 'PASSED', 'SKIPPED', 'FAILED', 'STANDARD_OUT', 'STANDARD_ERROR' + exceptionFormat = 'full' } } jar { manifest { attributes( - "Class-Path": configurations.runtimeClasspath.collect { it.getName() }.join(" ") + 'Class-Path': configurations.runtimeClasspath.collect { it.getName() }.join(' ') ) } } shadowJar { - archiveBaseName = "sliding-windows-standalone" + archiveBaseName = 'sliding-windows-standalone' archiveClassifier = '' } diff --git a/sorting/flinksql/build.gradle b/sorting/flinksql/build.gradle index b2b95b81..c860d1b4 100644 --- a/sorting/flinksql/build.gradle +++ b/sorting/flinksql/build.gradle @@ -13,7 +13,7 @@ java { sourceCompatibility = JavaVersion.VERSION_17 targetCompatibility = JavaVersion.VERSION_17 } -version = "0.0.1" +version = '0.0.1' repositories { mavenCentral() diff --git a/splitting/flinksql/build.gradle b/splitting/flinksql/build.gradle index b2b95b81..c860d1b4 100644 --- a/splitting/flinksql/build.gradle +++ b/splitting/flinksql/build.gradle @@ -13,7 +13,7 @@ java { sourceCompatibility = JavaVersion.VERSION_17 targetCompatibility = JavaVersion.VERSION_17 } -version = "0.0.1" +version = '0.0.1' repositories { mavenCentral() diff --git a/splitting/kstreams/build.gradle b/splitting/kstreams/build.gradle index b00a831e..50c620fa 100644 --- a/splitting/kstreams/build.gradle +++ b/splitting/kstreams/build.gradle @@ -5,8 +5,8 @@ buildscript { } plugins { - id "java" - id "application" + id 'java' + id 'application' id 'com.github.johnrengelman.shadow' version '8.1.1' } @@ -16,7 +16,7 @@ java { } application { - mainClass = "io.confluent.developer.SplitStream" + mainClass = 'io.confluent.developer.SplitStream' } repositories { @@ -26,17 +26,17 @@ repositories { dependencies { implementation project(':common') - implementation "org.slf4j:slf4j-simple:2.0.7" + implementation 'org.slf4j:slf4j-simple:2.0.7' implementation 'org.apache.kafka:kafka-streams:4.0.0' implementation('org.apache.kafka:kafka-clients') { version { strictly '4.0.0' } } - implementation "io.confluent:kafka-streams-avro-serde:7.5.1" - implementation "com.typesafe:config:1.4.2" + implementation 'io.confluent:kafka-streams-avro-serde:7.5.1' + implementation 'com.typesafe:config:1.4.2' - testImplementation "org.apache.kafka:kafka-streams-test-utils:4.0.0" + testImplementation 'org.apache.kafka:kafka-streams-test-utils:4.0.0' testImplementation 'org.junit.jupiter:junit-jupiter-api:5.9.2' testImplementation 'org.hamcrest:hamcrest:2.2' testRuntimeOnly 'org.junit.platform:junit-platform-launcher' @@ -48,20 +48,20 @@ test { testLogging { outputs.upToDateWhen { false } showStandardStreams = true - events "PASSED", "SKIPPED", "FAILED", "STANDARD_OUT", "STANDARD_ERROR" - exceptionFormat = "full" + events 'PASSED', 'SKIPPED', 'FAILED', 'STANDARD_OUT', 'STANDARD_ERROR' + exceptionFormat = 'full' } } jar { manifest { attributes( - "Class-Path": configurations.runtimeClasspath.collect { it.getName() }.join(" ") + 'Class-Path': configurations.runtimeClasspath.collect { it.getName() }.join(' ') ) } } shadowJar { - archiveBaseName = "splitting-standalone" + archiveBaseName = 'splitting-standalone' archiveClassifier = '' } diff --git a/streams-to-table/kstreams/build.gradle b/streams-to-table/kstreams/build.gradle index 8ae3a56c..066ac167 100644 --- a/streams-to-table/kstreams/build.gradle +++ b/streams-to-table/kstreams/build.gradle @@ -5,8 +5,8 @@ buildscript { } plugins { - id "java" - id "application" + id 'java' + id 'application' id 'com.github.johnrengelman.shadow' version '8.1.1' } @@ -16,7 +16,7 @@ java { } application { - mainClass = "io.confluent.developer.TransformStream" + mainClass = 'io.confluent.developer.TransformStream' } repositories { @@ -26,17 +26,17 @@ repositories { dependencies { implementation project(':common') - implementation "org.slf4j:slf4j-simple:2.0.7" + implementation 'org.slf4j:slf4j-simple:2.0.7' implementation 'org.apache.kafka:kafka-streams:4.0.0' implementation('org.apache.kafka:kafka-clients') { version { strictly '4.0.0' } } - implementation "io.confluent:kafka-streams-avro-serde:7.5.1" - implementation "com.typesafe:config:1.4.2" + implementation 'io.confluent:kafka-streams-avro-serde:7.5.1' + implementation 'com.typesafe:config:1.4.2' - testImplementation "org.apache.kafka:kafka-streams-test-utils:4.0.0" + testImplementation 'org.apache.kafka:kafka-streams-test-utils:4.0.0' testImplementation 'org.junit.jupiter:junit-jupiter-api:5.9.2' testImplementation 'org.hamcrest:hamcrest:2.2' testRuntimeOnly 'org.junit.platform:junit-platform-launcher' @@ -48,20 +48,20 @@ test { testLogging { outputs.upToDateWhen { false } showStandardStreams = true - events "PASSED", "SKIPPED", "FAILED", "STANDARD_OUT", "STANDARD_ERROR" - exceptionFormat = "full" + events 'PASSED', 'SKIPPED', 'FAILED', 'STANDARD_OUT', 'STANDARD_ERROR' + exceptionFormat = 'full' } } jar { manifest { attributes( - "Class-Path": configurations.runtimeClasspath.collect { it.getName() }.join(" ") + 'Class-Path': configurations.runtimeClasspath.collect { it.getName() }.join(' ') ) } } shadowJar { - archiveBaseName = "streams-to-table-standalone" + archiveBaseName = 'streams-to-table-standalone' archiveClassifier = '' } diff --git a/top-N/flinksql/build.gradle b/top-N/flinksql/build.gradle index 15d9a151..564c2466 100644 --- a/top-N/flinksql/build.gradle +++ b/top-N/flinksql/build.gradle @@ -13,7 +13,7 @@ java { sourceCompatibility = JavaVersion.VERSION_17 targetCompatibility = JavaVersion.VERSION_17 } -version = "0.0.1" +version = '0.0.1' repositories { mavenCentral() diff --git a/transforming/kstreams/build.gradle b/transforming/kstreams/build.gradle index 6df2c797..a1b1e87d 100644 --- a/transforming/kstreams/build.gradle +++ b/transforming/kstreams/build.gradle @@ -5,8 +5,8 @@ buildscript { } plugins { - id "java" - id "application" + id 'java' + id 'application' id 'com.github.johnrengelman.shadow' version '8.1.1' } @@ -16,7 +16,7 @@ java { } application { - mainClass = "io.confluent.developer.TransformStream" + mainClass = 'io.confluent.developer.TransformStream' } repositories { @@ -26,17 +26,17 @@ repositories { dependencies { implementation project(':common') - implementation "org.slf4j:slf4j-simple:2.0.7" + implementation 'org.slf4j:slf4j-simple:2.0.7' implementation 'org.apache.kafka:kafka-streams:4.0.0' implementation('org.apache.kafka:kafka-clients') { version { strictly '4.0.0' } } - implementation "io.confluent:kafka-streams-avro-serde:7.5.1" - implementation "com.typesafe:config:1.4.2" + implementation 'io.confluent:kafka-streams-avro-serde:7.5.1' + implementation 'com.typesafe:config:1.4.2' - testImplementation "org.apache.kafka:kafka-streams-test-utils:4.0.0" + testImplementation 'org.apache.kafka:kafka-streams-test-utils:4.0.0' testImplementation 'org.junit.jupiter:junit-jupiter-api:5.9.2' testImplementation 'org.hamcrest:hamcrest:2.2' testRuntimeOnly 'org.junit.platform:junit-platform-launcher' @@ -48,20 +48,20 @@ test { testLogging { outputs.upToDateWhen { false } showStandardStreams = true - events "PASSED", "SKIPPED", "FAILED", "STANDARD_OUT", "STANDARD_ERROR" - exceptionFormat = "full" + events 'PASSED', 'SKIPPED', 'FAILED', 'STANDARD_OUT', 'STANDARD_ERROR' + exceptionFormat = 'full' } } jar { manifest { attributes( - "Class-Path": configurations.runtimeClasspath.collect { it.getName() }.join(" ") + 'Class-Path': configurations.runtimeClasspath.collect { it.getName() }.join(' ') ) } } shadowJar { - archiveBaseName = "transforming-standalone" + archiveBaseName = 'transforming-standalone' archiveClassifier = '' } diff --git a/tumbling-windows/flinksql/build.gradle b/tumbling-windows/flinksql/build.gradle index b2b95b81..c860d1b4 100644 --- a/tumbling-windows/flinksql/build.gradle +++ b/tumbling-windows/flinksql/build.gradle @@ -13,7 +13,7 @@ java { sourceCompatibility = JavaVersion.VERSION_17 targetCompatibility = JavaVersion.VERSION_17 } -version = "0.0.1" +version = '0.0.1' repositories { mavenCentral() diff --git a/tumbling-windows/kstreams/build.gradle b/tumbling-windows/kstreams/build.gradle index 5b0ef3f5..f99de3df 100644 --- a/tumbling-windows/kstreams/build.gradle +++ b/tumbling-windows/kstreams/build.gradle @@ -13,8 +13,8 @@ buildscript { } plugins { - id "java" - id "application" + id 'java' + id 'application' id 'com.github.johnrengelman.shadow' version '8.1.1' } @@ -24,7 +24,7 @@ java { } application { - mainClass = "io.confluent.developer.TumblingWindow" + mainClass = 'io.confluent.developer.TumblingWindow' } repositories { @@ -35,17 +35,17 @@ repositories { dependencies { implementation project(':common') - implementation "org.slf4j:slf4j-simple:2.0.7" + implementation 'org.slf4j:slf4j-simple:2.0.7' implementation 'org.apache.kafka:kafka-streams:4.0.0' implementation('org.apache.kafka:kafka-clients') { version { strictly '4.0.0' } } - implementation "io.confluent:kafka-streams-avro-serde:7.5.1" - implementation "com.typesafe:config:1.4.2" + implementation 'io.confluent:kafka-streams-avro-serde:7.5.1' + implementation 'com.typesafe:config:1.4.2' - testImplementation "org.apache.kafka:kafka-streams-test-utils:4.0.0" + testImplementation 'org.apache.kafka:kafka-streams-test-utils:4.0.0' testImplementation 'org.junit.jupiter:junit-jupiter-api:5.9.2' testImplementation 'org.hamcrest:hamcrest:2.2' testRuntimeOnly 'org.junit.platform:junit-platform-launcher' @@ -57,20 +57,20 @@ test { testLogging { outputs.upToDateWhen { false } showStandardStreams = true - events "PASSED", "SKIPPED", "FAILED", "STANDARD_OUT", "STANDARD_ERROR" - exceptionFormat = "full" + events 'PASSED', 'SKIPPED', 'FAILED', 'STANDARD_OUT', 'STANDARD_ERROR' + exceptionFormat = 'full' } } jar { manifest { attributes( - "Class-Path": configurations.runtimeClasspath.collect { it.getName() }.join(" ") + 'Class-Path': configurations.runtimeClasspath.collect { it.getName() }.join(' ') ) } } shadowJar { - archiveBaseName = "tumbling-windows-standalone" + archiveBaseName = 'tumbling-windows-standalone' archiveClassifier = '' } diff --git a/udf/ksql/build.gradle b/udf/ksql/build.gradle index d0138dd6..c6e65f52 100644 --- a/udf/ksql/build.gradle +++ b/udf/ksql/build.gradle @@ -5,8 +5,8 @@ buildscript { } plugins { - id "java" - id "com.github.johnrengelman.shadow" version "8.1.1" + id 'java' + id 'com.github.johnrengelman.shadow' version '8.1.1' } java { @@ -32,20 +32,20 @@ test { testLogging { outputs.upToDateWhen { false } showStandardStreams = true - events "PASSED", "SKIPPED", "FAILED", "STANDARD_OUT", "STANDARD_ERROR" - exceptionFormat = "full" + events 'PASSED', 'SKIPPED', 'FAILED', 'STANDARD_OUT', 'STANDARD_ERROR' + exceptionFormat = 'full' } } jar { manifest { attributes( - "Class-Path": configurations.runtimeClasspath.collect { it.getName() }.join(" ") + 'Class-Path': configurations.runtimeClasspath.collect { it.getName() }.join(' ') ) } } shadowJar { - archiveBaseName = "ksql-udf" + archiveBaseName = 'ksql-udf' archiveClassifier = '' } diff --git a/versioned-ktables/kstreams/build.gradle b/versioned-ktables/kstreams/build.gradle index 388277dd..7b4f0558 100644 --- a/versioned-ktables/kstreams/build.gradle +++ b/versioned-ktables/kstreams/build.gradle @@ -5,8 +5,8 @@ buildscript { } plugins { - id "java" - id "application" + id 'java' + id 'application' id 'com.github.johnrengelman.shadow' version '8.1.1' } @@ -16,7 +16,7 @@ java { } application { - mainClass = "io.confluent.developer.VersionedKTableExample" + mainClass = 'io.confluent.developer.VersionedKTableExample' } repositories { @@ -27,17 +27,17 @@ repositories { dependencies { implementation project(':common') - implementation "org.slf4j:slf4j-simple:2.0.7" + implementation 'org.slf4j:slf4j-simple:2.0.7' implementation 'org.apache.kafka:kafka-streams:4.0.0' implementation('org.apache.kafka:kafka-clients') { version { strictly '4.0.0' } } - implementation "io.confluent:kafka-streams-avro-serde:7.5.1" - implementation "com.typesafe:config:1.4.2" + implementation 'io.confluent:kafka-streams-avro-serde:7.5.1' + implementation 'com.typesafe:config:1.4.2' - testImplementation "org.apache.kafka:kafka-streams-test-utils:4.0.0" + testImplementation 'org.apache.kafka:kafka-streams-test-utils:4.0.0' testImplementation 'org.junit.jupiter:junit-jupiter-api:5.9.2' testImplementation 'org.hamcrest:hamcrest:2.2' testRuntimeOnly 'org.junit.platform:junit-platform-launcher' @@ -49,21 +49,21 @@ test { testLogging { outputs.upToDateWhen { false } showStandardStreams = true - events "PASSED", "SKIPPED", "FAILED", "STANDARD_OUT", "STANDARD_ERROR" - exceptionFormat = "full" + events 'PASSED', 'SKIPPED', 'FAILED', 'STANDARD_OUT', 'STANDARD_ERROR' + exceptionFormat = 'full' } } jar { manifest { attributes( - "Class-Path": configurations.compileClasspath.collect { it.getName() }.join(" "), - "Main-Class": "io.confluent.developer.VersionedKTableExample" + 'Class-Path': configurations.compileClasspath.collect { it.getName() }.join(' '), + 'Main-Class': 'io.confluent.developer.VersionedKTableExample' ) } } shadowJar { - archiveBaseName = "versioned-ktables-standalone" + archiveBaseName = 'versioned-ktables-standalone' archiveClassifier = '' } diff --git a/window-final-result/kstreams/build.gradle b/window-final-result/kstreams/build.gradle index b29b30d3..1d57df85 100644 --- a/window-final-result/kstreams/build.gradle +++ b/window-final-result/kstreams/build.gradle @@ -5,8 +5,8 @@ buildscript { } plugins { - id "java" - id "application" + id 'java' + id 'application' id 'com.github.johnrengelman.shadow' version '8.1.1' } @@ -16,7 +16,7 @@ java { } application { - mainClass = "io.confluent.developer.WindowFinalResult" + mainClass = 'io.confluent.developer.WindowFinalResult' } repositories { @@ -27,17 +27,17 @@ repositories { dependencies { implementation project(':common') - implementation "org.slf4j:slf4j-simple:2.0.7" + implementation 'org.slf4j:slf4j-simple:2.0.7' implementation 'org.apache.kafka:kafka-streams:4.0.0' implementation('org.apache.kafka:kafka-clients') { version { strictly '4.0.0' } } - implementation "io.confluent:kafka-streams-avro-serde:7.5.1" - implementation "com.typesafe:config:1.4.2" + implementation 'io.confluent:kafka-streams-avro-serde:7.5.1' + implementation 'com.typesafe:config:1.4.2' - testImplementation "org.apache.kafka:kafka-streams-test-utils:4.0.0" + testImplementation 'org.apache.kafka:kafka-streams-test-utils:4.0.0' testImplementation 'org.junit.jupiter:junit-jupiter-api:5.9.2' testImplementation 'org.hamcrest:hamcrest:2.2' testRuntimeOnly 'org.junit.platform:junit-platform-launcher' @@ -49,20 +49,20 @@ test { testLogging { outputs.upToDateWhen { false } showStandardStreams = true - events "PASSED", "SKIPPED", "FAILED", "STANDARD_OUT", "STANDARD_ERROR" - exceptionFormat = "full" + events 'PASSED', 'SKIPPED', 'FAILED', 'STANDARD_OUT', 'STANDARD_ERROR' + exceptionFormat = 'full' } } jar { manifest { attributes( - "Class-Path": configurations.runtimeClasspath.collect { it.getName() }.join(" ") + 'Class-Path': configurations.runtimeClasspath.collect { it.getName() }.join(' ') ) } } shadowJar { - archiveBaseName = "window-final-result-standalone" + archiveBaseName = 'window-final-result-standalone' archiveClassifier = '' } diff --git a/windowed-top-N/flinksql/build.gradle b/windowed-top-N/flinksql/build.gradle index 15d9a151..564c2466 100644 --- a/windowed-top-N/flinksql/build.gradle +++ b/windowed-top-N/flinksql/build.gradle @@ -13,7 +13,7 @@ java { sourceCompatibility = JavaVersion.VERSION_17 targetCompatibility = JavaVersion.VERSION_17 } -version = "0.0.1" +version = '0.0.1' repositories { mavenCentral()