giving up on kafka connect websockets, it doesn't work and there's no error messages and the documentaiton sucks

This commit is contained in:
Adam 2021-12-27 12:44:37 +01:00
parent 2ad0c2848c
commit 55bea4aed4
4 changed files with 18 additions and 7 deletions

View file

@ -37,7 +37,6 @@ kotlinSerialization = { id = "org.jetbrains.kotlin.kotlin-serialization", vers
loggingCapabilities = { id = "dev.jacomet.logging-capabilities", version = "0.9.0" } loggingCapabilities = { id = "dev.jacomet.logging-capabilities", version = "0.9.0" }
shadowJar = { id = "com.github.jengelman.gradle.plugins.shadow", version = "6.1.0" } shadowJar = { id = "com.github.jengelman.gradle.plugins.shadow", version = "6.1.0" }
dependencyCheck = { id = "com.github.ben-manes.versions", version = "0.39.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" } http4k-graphql = { group = "org.http4k", name = "http4k-graphql" }
### jackson ## ### jackson ##
#jackson-bom = { 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.+" } #jackson-kotlin = { group = " com.fasterxml.jackson.module", name = ":jackson-module-kotlin", version = "2.13.+" }
## logging ## ## logging ##
slf4j-api = { group = "org.slf4j", name = "slf4j-api", version.ref = "slf4j" } slf4j-api = { group = "org.slf4j", name = "slf4j-api", version.ref = "slf4j" }

View file

@ -12,7 +12,7 @@ description = """
val projectId: String by project.extra val projectId: String by project.extra
@Suppress("UnstableApiUsage") @Suppress("UnstableApiUsage") // platform + version-catalog is incubating
dependencies { dependencies {
implementation("org.apache.kafka:kafka-streams:3.0.0") implementation("org.apache.kafka:kafka-streams:3.0.0")
@ -21,10 +21,12 @@ dependencies {
// implementation("com.ionspin.kotlin:bignum:0.3.3") // 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.core)
implementation(libs.kotlinx.serialization.json) implementation(libs.kotlinx.serialization.json)
implementation(libs.kotlinx.coroutines)
implementation(platform(libs.http4k.bom)) implementation(platform(libs.http4k.bom))
// implementation(libs.http4k.core) // implementation(libs.http4k.core)
implementation(libs.http4k.cloudnative) implementation(libs.http4k.cloudnative)
@ -36,7 +38,6 @@ dependencies {
implementation(libs.http4k.format.kotlinx) implementation(libs.http4k.format.kotlinx)
implementation(libs.bundles.logging) implementation(libs.bundles.logging)
} }
application { application {

View file

@ -39,7 +39,12 @@ dependencies {
implementation("org.jetbrains.kotlinx:kotlinx-serialization-json") implementation("org.jetbrains.kotlinx:kotlinx-serialization-json")
} }
// disabled for now...
val projectEnabled = false
val dockerBuildKafkaConnect by tasks.registering(Exec::class) { val dockerBuildKafkaConnect by tasks.registering(Exec::class) {
enabled = projectEnabled
group = "docker-compose" group = "docker-compose"
dependsOn(downloadCamelConnectors, tasks.dockerEnv) dependsOn(downloadCamelConnectors, tasks.dockerEnv)
@ -54,6 +59,8 @@ val dockerBuildKafkaConnect by tasks.registering(Exec::class) {
val downloadCamelConnectors by tasks.registering(Sync::class) { val downloadCamelConnectors by tasks.registering(Sync::class) {
enabled = projectEnabled
group = project.name group = project.name
description = "Retrieve Camel Kafka Connectors from Maven, in preparation for the Docker build" 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 { tasks.dockerUp {
enabled = projectEnabled
dependsOn(":modules:infra-kafka-cluster:dockerUp") dependsOn(":modules:infra-kafka-cluster:dockerUp")
dependsOn(downloadCamelConnectors) dependsOn(downloadCamelConnectors)
} }
tasks.dockerEnv { tasks.dockerEnv {
enabled = projectEnabled
properties( properties(
"CONNECTOR_ID" to "kafkatorio-connect", "CONNECTOR_ID" to "kafkatorio-connect",
"KAFKA_CONNECT_VERSION" to libs.versions.confluent.kafkaConnect.get(), "KAFKA_CONNECT_VERSION" to libs.versions.confluent.kafkaConnect.get(),

View file

@ -11,7 +11,7 @@ include(
":modules:infra-kafka-cluster", ":modules:infra-kafka-cluster",
":modules:infra-kafka-pipe", ":modules:infra-kafka-pipe",
// ":modules:infra-kafka-connect", ":modules:infra-kafka-connect",
":modules:kt-rcon", ":modules:kt-rcon",
":modules:web-map", ":modules:web-map",