diff --git a/examples/spire_producer.example/spire_producer.example.go b/examples/spire_producer.example/spire_producer.example.go index a7fce9d95..e9c26e82c 100644 --- a/examples/spire_producer.example/spire_producer.example.go +++ b/examples/spire_producer.example/spire_producer.example.go @@ -61,6 +61,7 @@ func retrieveJWTToken(ctx context.Context, principal, socketPath string, audienc ctx, workloadapi.WithClientOptions(workloadapi.WithAddr(socketPath)), ) + //workloadapi.ValidateJWTSVID() if err != nil { return kafka.OAuthBearerToken{}, nil, fmt.Errorf("unable to create JWTSource: %w", err) }