allow override the Schema Creator by a reader

adrianiacobghiula · Mar 3, 2024 · 1ea39fe · 1ea39fe
1 parent 4938292
commit 1ea39fe
Show file tree

Hide file tree

Showing 2 changed files with 5 additions and 0 deletions.
diff --git a/pulsar/reader.go b/pulsar/reader.go
@@ -89,6 +89,10 @@ type ReaderOptions struct {
 	// Schema represents the schema implementation.
 	Schema Schema
 
+	// SchemaCreator allows to override the default creator of Schema based on schemaType, schemaData and properties
+	// will default to NewSchema if not set
+	SchemaCreator SchemaCreator
+
 	// BackoffPolicy parameterize the following options in the reconnection logic to
 	// allow users to customize the reconnection logic (minBackoff, maxBackoff and jitterPercentage)
 	BackoffPolicy internal.BackoffPolicy

diff --git a/pulsar/reader_impl.go b/pulsar/reader_impl.go
@@ -110,6 +110,7 @@ func newReader(client *client, options ReaderOptions) (Reader, error) {
 		ReplicateSubscriptionState:  false,
 		Decryption:                  options.Decryption,
 		Schema:                      options.Schema,
+		SchemaCreator:               options.SchemaCreator,
 		BackoffPolicy:               options.BackoffPolicy,
 		MaxPendingChunkedMessage:    options.MaxPendingChunkedMessage,
 		ExpireTimeOfIncompleteChunk: options.ExpireTimeOfIncompleteChunk,