Class ExtJsonConverter
- java.lang.Object
-
- io.apicurio.registry.serde.SchemaResolverConfigurer<com.fasterxml.jackson.databind.JsonNode,Object>
-
- io.apicurio.registry.utils.converter.ExtJsonConverter
-
- All Implemented Interfaces:
io.apicurio.registry.serde.SchemaParser<com.fasterxml.jackson.databind.JsonNode>
,AutoCloseable
,org.apache.kafka.connect.storage.Converter
public class ExtJsonConverter extends io.apicurio.registry.serde.SchemaResolverConfigurer<com.fasterxml.jackson.databind.JsonNode,Object> implements org.apache.kafka.connect.storage.Converter, io.apicurio.registry.serde.SchemaParser<com.fasterxml.jackson.databind.JsonNode>, AutoCloseable
- Author:
- Ales Justin, Fabian Martinez
-
-
Constructor Summary
Constructors Constructor Description ExtJsonConverter()
ExtJsonConverter(io.apicurio.registry.rest.client.RegistryClient client)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description io.apicurio.registry.types.ArtifactType
artifactType()
void
close()
void
configure(Map<String,?> configs, boolean isKey)
byte[]
fromConnectData(String topic, org.apache.kafka.common.header.Headers headers, org.apache.kafka.connect.data.Schema schema, Object value)
byte[]
fromConnectData(String topic, org.apache.kafka.connect.data.Schema schema, Object value)
com.fasterxml.jackson.databind.JsonNode
parseSchema(byte[] rawSchema)
ExtJsonConverter
setFormatStrategy(FormatStrategy formatStrategy)
org.apache.kafka.connect.data.SchemaAndValue
toConnectData(String topic, byte[] value)
-
Methods inherited from class io.apicurio.registry.serde.SchemaResolverConfigurer
configure, getSchemaResolver, setSchemaResolver
-
-
-
-
Method Detail
-
setFormatStrategy
public ExtJsonConverter setFormatStrategy(FormatStrategy formatStrategy)
-
configure
public void configure(Map<String,?> configs, boolean isKey)
- Specified by:
configure
in interfaceorg.apache.kafka.connect.storage.Converter
-
fromConnectData
public byte[] fromConnectData(String topic, org.apache.kafka.connect.data.Schema schema, Object value)
- Specified by:
fromConnectData
in interfaceorg.apache.kafka.connect.storage.Converter
-
fromConnectData
public byte[] fromConnectData(String topic, org.apache.kafka.common.header.Headers headers, org.apache.kafka.connect.data.Schema schema, Object value)
- Specified by:
fromConnectData
in interfaceorg.apache.kafka.connect.storage.Converter
-
toConnectData
public org.apache.kafka.connect.data.SchemaAndValue toConnectData(String topic, byte[] value)
- Specified by:
toConnectData
in interfaceorg.apache.kafka.connect.storage.Converter
-
artifactType
public io.apicurio.registry.types.ArtifactType artifactType()
- Specified by:
artifactType
in interfaceio.apicurio.registry.serde.SchemaParser<com.fasterxml.jackson.databind.JsonNode>
- See Also:
SchemaParser.artifactType()
-
parseSchema
public com.fasterxml.jackson.databind.JsonNode parseSchema(byte[] rawSchema)
- Specified by:
parseSchema
in interfaceio.apicurio.registry.serde.SchemaParser<com.fasterxml.jackson.databind.JsonNode>
- See Also:
SchemaParser.parseSchema(byte[])
-
close
public void close() throws Exception
- Specified by:
close
in interfaceAutoCloseable
- Throws:
Exception
- See Also:
AutoCloseable.close()
-
-