Uses of Class
io.confluent.kafka.serializers.schema.id.SchemaId
Packages that use SchemaId
-
Uses of SchemaId in io.confluent.kafka.serializers
Methods in io.confluent.kafka.serializers with parameters of type SchemaIdModifier and TypeMethodDescriptionprotected ParsedSchemaAbstractKafkaSchemaSerDe.getSchemaBySchemaId(String subject, SchemaId schemaId) -
Uses of SchemaId in io.confluent.kafka.serializers.schema.id
Methods in io.confluent.kafka.serializers.schema.id with parameters of type SchemaIdModifier and TypeMethodDescriptionConfigSchemaIdDeserializer.deserialize(String topic, boolean isKey, org.apache.kafka.common.header.Headers headers, byte[] payload, SchemaId schemaId) DualSchemaIdDeserializer.deserialize(String topic, boolean isKey, org.apache.kafka.common.header.Headers headers, byte[] payload, SchemaId schemaId) PrefixSchemaIdDeserializer.deserialize(String topic, boolean isKey, org.apache.kafka.common.header.Headers headers, byte[] payload, SchemaId schemaId) SchemaIdDeserializer.deserialize(String topic, boolean isKey, org.apache.kafka.common.header.Headers headers, byte[] payload, SchemaId schemaId) Deserialize the payload and set the schema identifier.byte[]HeaderSchemaIdSerializer.serialize(String topic, boolean isKey, org.apache.kafka.common.header.Headers headers, byte[] payload, SchemaId schemaId) byte[]PrefixSchemaIdSerializer.serialize(String topic, boolean isKey, org.apache.kafka.common.header.Headers headers, byte[] payload, SchemaId schemaId) byte[]SchemaIdSerializer.serialize(String topic, boolean isKey, org.apache.kafka.common.header.Headers headers, byte[] payload, SchemaId schemaId) Associates a schema identifier with the payload.