From bb773acb9c1a8a491eea94340a77cdd324971e8e Mon Sep 17 00:00:00 2001 From: Dana Powers Date: Sat, 16 Jul 2016 11:55:23 -0700 Subject: Add Boolean protocol type --- kafka/protocol/types.py | 10 ++++++++++ 1 file changed, 10 insertions(+) (limited to 'kafka/protocol') 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: -- cgit v1.2.1