public class ExtJsonConverter extends AbstractKafkaStrategyAwareSerDe<String,ExtJsonConverter> implements org.apache.kafka.connect.storage.Converter
REGISTRY_ARTIFACT_ID_STRATEGY_CONFIG_PARAM, REGISTRY_GLOBAL_ID_STRATEGY_CONFIG_PARAM
headerUtils, key, log, MAGIC_BYTE, REGISTRY_CACHED_CONFIG_PARAM, REGISTRY_CONFLUENT_ID_HANDLER_CONFIG_PARAM, REGISTRY_ID_HANDLER_CONFIG_PARAM, REGISTRY_REQUEST_HEADERS_PREFIX, REGISTRY_REQUEST_KEY_PASSWORD, REGISTRY_REQUEST_KEYSTORE_LOCATION, REGISTRY_REQUEST_KEYSTORE_PASSWORD, REGISTRY_REQUEST_KEYSTORE_TYPE, REGISTRY_REQUEST_TRUSTSTORE_LOCATION, REGISTRY_REQUEST_TRUSTSTORE_PASSWORD, REGISTRY_REQUEST_TRUSTSTORE_TYPE, REGISTRY_URL_CONFIG_PARAM, USE_HEADERS
Constructor and Description |
---|
ExtJsonConverter() |
ExtJsonConverter(io.apicurio.registry.client.RegistryService client) |
Modifier and Type | Method and Description |
---|---|
void |
configure(Map<String,?> configs,
boolean isKey) |
byte[] |
fromConnectData(String topic,
org.apache.kafka.connect.data.Schema schema,
Object value) |
ExtJsonConverter |
setFormatStrategy(FormatStrategy formatStrategy) |
org.apache.kafka.connect.data.SchemaAndValue |
toConnectData(String topic,
byte[] value) |
getArtifactIdStrategy, getGlobalIdStrategy, setArtifactIdStrategy, setGlobalIdStrategy
asLegacyId, close, getByteBuffer, getClient, getIdHandler, instantiate, instantiate, isKey, loadClass, reset, self, setIdHandler, setKey, toGlobalId
public ExtJsonConverter()
public ExtJsonConverter(io.apicurio.registry.client.RegistryService client)
public ExtJsonConverter setFormatStrategy(FormatStrategy formatStrategy)
public void configure(Map<String,?> configs, boolean isKey)
configure
in interface org.apache.kafka.connect.storage.Converter
configure
in class AbstractKafkaStrategyAwareSerDe<String,ExtJsonConverter>
public byte[] fromConnectData(String topic, org.apache.kafka.connect.data.Schema schema, Object value)
fromConnectData
in interface org.apache.kafka.connect.storage.Converter
public org.apache.kafka.connect.data.SchemaAndValue toConnectData(String topic, byte[] value)
toConnectData
in interface org.apache.kafka.connect.storage.Converter
Copyright © 2020 Red Hat. All rights reserved.