public class JsonSchemaKafkaSerializer<T> extends JsonSchemaKafkaSerDe<JsonSchemaKafkaSerializer<T>> implements org.apache.kafka.common.serialization.Serializer<T>
api, mapper
REGISTRY_ARTIFACT_ID_STRATEGY_CONFIG_PARAM, REGISTRY_GLOBAL_ID_STRATEGY_CONFIG_PARAM
log, MAGIC_BYTE, REGISTRY_CACHED_CONFIG_PARAM, REGISTRY_CONFLUENT_ID_HANDLER_CONFIG_PARAM, REGISTRY_ID_HANDLER_CONFIG_PARAM, REGISTRY_URL_CONFIG_PARAM
Constructor and Description |
---|
JsonSchemaKafkaSerializer()
Constructor.
|
JsonSchemaKafkaSerializer(RegistryService client,
Boolean validationEnabled)
Constructor.
|
Modifier and Type | Method and Description |
---|---|
protected void |
addSchemaHeaders(org.apache.kafka.common.header.Headers headers,
String artifactId,
long globalId)
Adds appropriate information to the Headers so that the deserializer can function properly.
|
protected void |
addTypeHeaders(org.apache.kafka.common.header.Headers headers,
T data)
Adds appropriate information to the Headers so that the deserializer can function properly.
|
protected String |
getArtifactId(String topic,
T data)
Figure out the artifact ID from the topic name and data.
|
protected long |
getGlobalId(String artifactId,
String topic,
T data)
Gets the global id of the schema to use for validation.
|
byte[] |
serialize(String topic,
org.apache.kafka.common.header.Headers headers,
T data) |
byte[] |
serialize(String topic,
T data) |
configure, getSchemaCache, isValidationEnabled, setValidationEnabled
getArtifactIdStrategy, getGlobalIdStrategy, isKey, setArtifactIdStrategy, setGlobalIdStrategy, setKey
asLegacyId, close, configure, getByteBuffer, getClient, getIdHandler, instantiate, instantiate, loadClass, reset, self, setIdHandler
public JsonSchemaKafkaSerializer()
public JsonSchemaKafkaSerializer(RegistryService client, Boolean validationEnabled)
client
- the clientvalidationEnabled
- the validation enabled flagpublic byte[] serialize(String topic, T data)
serialize
in interface org.apache.kafka.common.serialization.Serializer<T>
Serializer.serialize(java.lang.String, java.lang.Object)
public byte[] serialize(String topic, org.apache.kafka.common.header.Headers headers, T data)
serialize
in interface org.apache.kafka.common.serialization.Serializer<T>
Serializer.serialize(java.lang.String, org.apache.kafka.common.header.Headers, java.lang.Object)
protected String getArtifactId(String topic, T data)
topic
- the Kafka topicdata
- msg dataprotected long getGlobalId(String artifactId, String topic, T data)
artifactId
- artifact idtopic
- the topicdata
- the msg dataprotected void addSchemaHeaders(org.apache.kafka.common.header.Headers headers, String artifactId, long globalId)
headers
- msg headersartifactId
- artifact idglobalId
- global idprotected void addTypeHeaders(org.apache.kafka.common.header.Headers headers, T data)
headers
- the headersdata
- the msg dataCopyright © 2020 Red Hat. All rights reserved.