Reference: Kafka: Schema Registry

dependencies {
    
    implementation(platform("org.http4k:http4k-connect-bom:5.25.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:

FakeSchemaRegistry().start()