diff options
| -rw-r--r-- | kafka/protocol/types.py | 10 |
1 files changed, 10 insertions, 0 deletions
diff --git a/kafka/protocol/types.py b/kafka/protocol/types.py index 18aaca1..7fdfc9d 100644 --- a/kafka/protocol/types.py +++ b/kafka/protocol/types.py @@ -99,6 +99,16 @@ class Bytes(AbstractType): return value +class Boolean(AbstractType): + @classmethod + def encode(cls, value): + return _pack('>?', value) + + @classmethod + def decode(cls, data): + return _unpack('>?', data.read(1)) + + class Schema(AbstractType): def __init__(self, *fields): if fields: |