Package com.solace.serdes.avro.strategy

Class RecordIdStrategy

java.lang.Object

com.solace.serdes.avro.strategy.RecordIdStrategy

All Implemented Interfaces:

ArtifactReferenceResolverStrategy<Object,org.apache.avro.Schema>

public class RecordIdStrategy
extends Object
implements ArtifactReferenceResolverStrategy<Object,org.apache.avro.Schema>

An implementation of ArtifactReferenceResolverStrategy that resolves artifact references based on the record ID for Avro schemas. This strategy extracts the artifact ID and group ID from the Avro schema's name and namespace, respectively, using the provided ParsedSchema.

Constructor Summary

Constructors

Constructor	Description
RecordIdStrategy()	Constructs a new RecordIdStrategy.

Method Summary

Modifier and Type	Method	Description
ArtifactReference	artifactReference(Record<Object> data, ParsedSchema<org.apache.avro.Schema> parsedSchema)	Resolves and returns the ArtifactReference for a given ParsedSchema.

Methods inherited from class java.lang.Object

equals, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface com.solace.serdes.common.resolver.strategy.ArtifactReferenceResolverStrategy

loadSchema

Constructor Detail

RecordIdStrategy

public RecordIdStrategy()

Constructs a new RecordIdStrategy.

Method Detail

artifactReference

public ArtifactReference artifactReference(Record<Object> data,
                                           ParsedSchema<org.apache.avro.Schema> parsedSchema)

Resolves and returns the ArtifactReference for a given ParsedSchema. This method uses the schema provided in the ParsedSchema to extract the schema's name as the artifactId and the schema's namespace as the groupId to build the ArtifactReference.

Specified by:

artifactReference in interface ArtifactReferenceResolverStrategy<Object,org.apache.avro.Schema>

Parameters:

data - The Avro record for which to resolve the ArtifactReference. Note: This parameter is not used in the current implementation.

parsedSchema - The parsed schema of the record, used to extract the artifact reference information.

Returns:

An ArtifactReference containing the artifact ID and group ID derived from the ParsedSchema.