Class 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 Detail

      • ExtJsonConverter

        public ExtJsonConverter()
      • ExtJsonConverter

        public ExtJsonConverter​(io.apicurio.registry.rest.client.RegistryClient client)
    • Method Detail

      • configure

        public void configure​(Map<String,​?> configs,
                              boolean isKey)
        Specified by:
        configure in interface org.apache.kafka.connect.storage.Converter
      • fromConnectData

        public byte[] fromConnectData​(String topic,
                                      org.apache.kafka.connect.data.Schema schema,
                                      Object value)
        Specified by:
        fromConnectData in interface org.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 interface org.apache.kafka.connect.storage.Converter
      • toConnectData

        public org.apache.kafka.connect.data.SchemaAndValue toConnectData​(String topic,
                                                                          byte[] value)
        Specified by:
        toConnectData in interface org.apache.kafka.connect.storage.Converter
      • artifactType

        public io.apicurio.registry.types.ArtifactType artifactType()
        Specified by:
        artifactType in interface io.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 interface io.apicurio.registry.serde.SchemaParser<com.fasterxml.jackson.databind.JsonNode>
        See Also:
        SchemaParser.parseSchema(byte[])