feat(fxgcppubsub): Added schemas support

ankorstore · Jun 5, 2024 · 3912f1d · 3912f1d
1 parent abb6ea5
commit 3912f1d
Showing 1 changed file with 2 additions and 0 deletions.
diff --git a/fxgcppubsub/schema/registry.go b/fxgcppubsub/schema/registry.go
@@ -2,6 +2,7 @@ package schema
 
 import (
 	"context"
+	"fmt"
 	"sync"
 
 	"cloud.google.com/go/pubsub"
@@ -30,6 +31,7 @@ func (r *SchemaRegistry) Get(ctx context.Context, schemaID string) (*pubsub.Sche
 
 	schema, err := r.client.Schema(ctx, schemaID, pubsub.SchemaViewFull)
 	if err != nil {
+		fmt.Printf("error: %s\n", err)
 		return nil, err
 	}