From 55bea4aed47f70113d3d1219c0374c4cc262ba7e Mon Sep 17 00:00:00 2001 From: Adam <897017+aSemy@users.noreply.github.com> Date: Mon, 27 Dec 2021 12:44:37 +0100 Subject: [PATCH] giving up on kafka connect websockets, it doesn't work and there's no error messages and the documentaiton sucks --- gradle/libs.versions.toml | 5 ++--- modules/events-processor/build.gradle.kts | 7 ++++--- modules/infra-kafka-connect/build.gradle.kts | 11 +++++++++++ settings.gradle.kts | 2 +- 4 files changed, 18 insertions(+), 7 deletions(-) diff --git a/gradle/libs.versions.toml b/gradle/libs.versions.toml index 877b863..edf618f 100644 --- a/gradle/libs.versions.toml +++ b/gradle/libs.versions.toml @@ -37,7 +37,6 @@ kotlinSerialization = { id = "org.jetbrains.kotlin.kotlin-serialization", vers loggingCapabilities = { id = "dev.jacomet.logging-capabilities", version = "0.9.0" } shadowJar = { id = "com.github.jengelman.gradle.plugins.shadow", version = "6.1.0" } dependencyCheck = { id = "com.github.ben-manes.versions", version = "0.39.0" } -axionRelease = { id = "pl.allegro.tech.build.axion-release", version = "1.13.3" } ########### @@ -69,8 +68,8 @@ http4k-format-kotlinx = { group = "org.http4k", name = "http4k-format-kotlinx-s http4k-graphql = { group = "org.http4k", name = "http4k-graphql" } ### jackson ## -#jackson-bom = { group = " com.fasterxml.jackson.module", name = ":jackson-module-kotlin", version = "2.13.+" } -#jackson-kotlin = { group = " com.fasterxml.jackson.module", name = ":jackson-module-kotlin", version = "2.13.+" } +#jackson-bom = { group = " com.fasterxml.jackson.module", name = ":jackson-module-kotlin", version = "2.13.+" } +#jackson-kotlin = { group = " com.fasterxml.jackson.module", name = ":jackson-module-kotlin", version = "2.13.+" } ## logging ## slf4j-api = { group = "org.slf4j", name = "slf4j-api", version.ref = "slf4j" } diff --git a/modules/events-processor/build.gradle.kts b/modules/events-processor/build.gradle.kts index 2066d02..dd7b8f6 100644 --- a/modules/events-processor/build.gradle.kts +++ b/modules/events-processor/build.gradle.kts @@ -12,7 +12,7 @@ description = """ val projectId: String by project.extra -@Suppress("UnstableApiUsage") +@Suppress("UnstableApiUsage") // platform + version-catalog is incubating dependencies { implementation("org.apache.kafka:kafka-streams:3.0.0") @@ -21,10 +21,12 @@ dependencies { // implementation("com.ionspin.kotlin:bignum:0.3.3") - implementation(enforcedPlatform(libs.kotlinx.serialization.bom)) + implementation(platform(libs.kotlinx.serialization.bom)) implementation(libs.kotlinx.serialization.core) implementation(libs.kotlinx.serialization.json) + implementation(libs.kotlinx.coroutines) + implementation(platform(libs.http4k.bom)) // implementation(libs.http4k.core) implementation(libs.http4k.cloudnative) @@ -36,7 +38,6 @@ dependencies { implementation(libs.http4k.format.kotlinx) implementation(libs.bundles.logging) - } application { diff --git a/modules/infra-kafka-connect/build.gradle.kts b/modules/infra-kafka-connect/build.gradle.kts index a233462..30c163a 100644 --- a/modules/infra-kafka-connect/build.gradle.kts +++ b/modules/infra-kafka-connect/build.gradle.kts @@ -39,7 +39,12 @@ dependencies { implementation("org.jetbrains.kotlinx:kotlinx-serialization-json") } +// disabled for now... +val projectEnabled = false + val dockerBuildKafkaConnect by tasks.registering(Exec::class) { + enabled = projectEnabled + group = "docker-compose" dependsOn(downloadCamelConnectors, tasks.dockerEnv) @@ -54,6 +59,8 @@ val dockerBuildKafkaConnect by tasks.registering(Exec::class) { val downloadCamelConnectors by tasks.registering(Sync::class) { + enabled = projectEnabled + group = project.name description = "Retrieve Camel Kafka Connectors from Maven, in preparation for the Docker build" @@ -82,11 +89,15 @@ val downloadCamelConnectors by tasks.registering(Sync::class) { } tasks.dockerUp { + enabled = projectEnabled + dependsOn(":modules:infra-kafka-cluster:dockerUp") dependsOn(downloadCamelConnectors) } tasks.dockerEnv { + enabled = projectEnabled + properties( "CONNECTOR_ID" to "kafkatorio-connect", "KAFKA_CONNECT_VERSION" to libs.versions.confluent.kafkaConnect.get(), diff --git a/settings.gradle.kts b/settings.gradle.kts index a99134d..3af2206 100644 --- a/settings.gradle.kts +++ b/settings.gradle.kts @@ -11,7 +11,7 @@ include( ":modules:infra-kafka-cluster", ":modules:infra-kafka-pipe", -// ":modules:infra-kafka-connect", + ":modules:infra-kafka-connect", ":modules:kt-rcon", ":modules:web-map",