package schemaid
Ordering
- Alphabetic
Visibility
- Public
- All
Type Members
- class InvalidSchemaIdHeader extends IllegalArgumentException
-
class
SchemaIdFromNuHeadersPotentiallyShiftingConfluentPayload extends SchemaIdFromMessageExtractor
This class basically extract schema id from our specific headers: key/value.schemaId.
This class basically extract schema id from our specific headers: key/value.schemaId. Because we always produce those headers, we can have situation when schema id is in headers but also payload is in Confluent format (magic byte + schema id + bytes). Because of that we need to shift this payload so next step (payload deserializer) will have clear situation - buffer pointer pointing to bytes with message
Value Members
- object SchemaIdFromNuHeadersPotentiallyShiftingConfluentPayload extends Serializable
- object SchemaIdFromPayloadInConfluentFormat extends SchemaIdFromMessageExtractor