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: