Use string schema for crypto function input

jiangpengcheng · jiangpengcheng · commit d3a0febdf024 · 2026-05-29T21:55:29.000+08:00
diff --git a/.ci/tests/integration/cases/crypto-function/manifests.yaml b/.ci/tests/integration/cases/crypto-function/manifests.yaml
@@ -16,7 +16,7 @@ spec:
     typeClassName: java.lang.String
     sourceSpecs:
       "persistent://public/default/java-function-crypto-input-topic":
-        schemaType: java.lang.String
+        schemaType: STRING
         cryptoConfig:
           cryptoKeyReaderClassName: "org.apache.pulsar.functions.api.examples.RawFileKeyReader"
           cryptoKeyReaderConfig:
diff --git a/config/samples/compute_v1alpha1_function_crypto.yaml b/config/samples/compute_v1alpha1_function_crypto.yaml
@@ -17,7 +17,7 @@ spec:
     typeClassName: java.lang.String
     sourceSpecs:
       "persistent://public/default/java-function-crypto-input-topic":
-        schemaType: java.lang.String
+        schemaType: STRING
         cryptoConfig:
           cryptoKeyReaderClassName: "org.apache.pulsar.functions.api.examples.RawFileKeyReader"
           cryptoKeyReaderConfig:
