You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@pulsar.apache.org by mm...@apache.org on 2019/06/04 14:16:35 UTC
[pulsar] branch master updated: get boolean schema from schemaInfo
(#4459)
This is an automated email from the ASF dual-hosted git repository.
mmerli pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/pulsar.git
The following commit(s) were added to refs/heads/master by this push:
new d0dffd6 get boolean schema from schemaInfo (#4459)
d0dffd6 is described below
commit d0dffd6bf0da06dc1c0d29f36c7ffde2055503aa
Author: Yijie Shen <he...@gmail.com>
AuthorDate: Tue Jun 4 22:16:29 2019 +0800
get boolean schema from schemaInfo (#4459)
---
.../java/org/apache/pulsar/client/impl/schema/AutoConsumeSchema.java | 2 ++
1 file changed, 2 insertions(+)
diff --git a/pulsar-client/src/main/java/org/apache/pulsar/client/impl/schema/AutoConsumeSchema.java b/pulsar-client/src/main/java/org/apache/pulsar/client/impl/schema/AutoConsumeSchema.java
index 050716a..845af6a 100644
--- a/pulsar-client/src/main/java/org/apache/pulsar/client/impl/schema/AutoConsumeSchema.java
+++ b/pulsar-client/src/main/java/org/apache/pulsar/client/impl/schema/AutoConsumeSchema.java
@@ -96,6 +96,8 @@ public class AutoConsumeSchema implements Schema<GenericRecord> {
return FloatSchema.of();
case DOUBLE:
return DoubleSchema.of();
+ case BOOLEAN:
+ return BooleanSchema.of();
case BYTES:
return BytesSchema.of();
case DATE: