Reference: Kafka: Schema Registry
dependencies {
implementation(platform("org.http4k:http4k-bom:6.0.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()