diff --git a/examples/streaming-push-dataplane/consumer/dataplane.go b/examples/streaming-push-dataplane/consumer/dataplane.go
index c40b151..533c330 100644
--- a/examples/streaming-push-dataplane/consumer/dataplane.go
+++ b/examples/streaming-push-dataplane/consumer/dataplane.go
@@ -40,7 +40,8 @@ func NewDataPlane(authService *natsservices.AuthService,
 	natsUrl string,
 	eventSubscriber *natsservices.EventSubscriber) (*ConsumerDataPlane, error) {
 
-	providerDataPlane := &ConsumerDataPlane{authService: authService,
+	providerDataPlane := &ConsumerDataPlane{
+		authService:           authService,
 		connectionInvalidator: invalidator,
 		natsUrl:               natsUrl,
 		eventSubscriber:       eventSubscriber}
diff --git a/examples/sync-pull-dataplane/main.go b/examples/sync-pull-dataplane/main.go
index 3d4f436..3e1bc1b 100644
--- a/examples/sync-pull-dataplane/main.go
+++ b/examples/sync-pull-dataplane/main.go
@@ -46,7 +46,7 @@ func main() {
 	consumerProcessID := uuid.NewString()
 	_, err = cp.ConsumerPrepare(ctx, consumerProcessID, agreementID, datasetID)
 	if err != nil {
-		log.Fatalf("Unable to send prepate to consumer control plane: %v\n", err)
+		log.Fatalf("Unable to send prepare to consumer control plane: %v\n", err)
 	}
 
 	// Signal to the provider data plane