Reference: Kafka: Schema Registry

dependencies {
    
    implementation(platform("org.http4k:http4k-bom:6.36.0.0"))

    implementation("org.http4k:http4k-connect-kafka-schemaregistry")
    implementation("org.http4k:http4k-connect-kafka-schemaregistry-fake")
}

The main SchemaRegistry connector provides the following Actions:

  • CheckSchemaRegistered
  • GetSchemaById
  • GetSubjects
  • GetSubjectVersion
  • GetSubjectVersions
  • RegisterSchema

Fake

The Fake provides the above actions.

Default Fake port: 41466

To start:

Kotlin fake.kt
package content.ecosystem.connect.reference.kafka.schemaregistry

import org.http4k.chaos.start
import org.http4k.connect.kafka.schemaregistry.FakeSchemaRegistry

val schemaRegistry = FakeSchemaRegistry().start()
scarf