This is an automated email from the ASF dual-hosted git repository. sanjeevrk pushed a commit to branch srkukarni/serverside_validation_endpoints in repository https://gitbox.apache.org/repos/asf/pulsar.git
commit 48f5233f3eb0975aaf37974b4aa1310f292f41f9 Author: Sanjeev Kulkarni <sanj...@streaml.io> AuthorDate: Thu Oct 4 20:09:24 2018 -0700 More better check --- .../src/main/java/org/apache/pulsar/functions/utils/SourceConfig.java | 3 ++- 1 file changed, 2 insertions(+), 1 deletion(-) diff --git a/pulsar-functions/utils/src/main/java/org/apache/pulsar/functions/utils/SourceConfig.java b/pulsar-functions/utils/src/main/java/org/apache/pulsar/functions/utils/SourceConfig.java index 38e200a..c1ff240 100644 --- a/pulsar-functions/utils/src/main/java/org/apache/pulsar/functions/utils/SourceConfig.java +++ b/pulsar-functions/utils/src/main/java/org/apache/pulsar/functions/utils/SourceConfig.java @@ -25,6 +25,7 @@ import lombok.Setter; import lombok.ToString; import org.apache.pulsar.client.api.Schema; import org.apache.pulsar.functions.api.SerDe; +import org.apache.pulsar.functions.utils.validation.ConfigValidationAnnotations; import org.apache.pulsar.functions.utils.validation.ConfigValidationAnnotations.NotNull; import org.apache.pulsar.functions.utils.validation.ConfigValidationAnnotations.isFileExists; import org.apache.pulsar.functions.utils.validation.ConfigValidationAnnotations.isImplementationOfClass; @@ -55,7 +56,7 @@ public class SourceConfig { @isValidTopicName private String topicName; - @isImplementationOfClass(implementsClass = SerDe.class) + @ConfigValidationAnnotations.isValidSerde private String serdeClassName; private String schemaType;