public interface GlobalIdStrategy<T>
GlobalIdStrategy
is used by the Kafka serializer/deserializer
to find global id for given schema in the registry.
The default is FindBySchemaIdStrategy
.Modifier and Type | Method and Description |
---|---|
long |
findId(RegistryService service,
String artifactId,
io.apicurio.registry.types.ArtifactType artifactType,
T schema)
For a given topic and message, returns the artifact id under which the
schema should be registered in the registry.
|
default InputStream |
toStream(T schema)
Create InputStream from schema.
|
long findId(RegistryService service, String artifactId, io.apicurio.registry.types.ArtifactType artifactType, T schema)
service
- the registry serviceartifactId
- the schema artifact idartifactType
- the artifact typeschema
- the schema of the message being serialized/deserializeddefault InputStream toStream(T schema)
schema
- the schemaCopyright © 2019 Red Hat. All rights reserved.