diff --git a/kafka/protocol/types.py b/kafka/protocol/types.py index b0811c59b..b7d1e3d01 100644 --- a/kafka/protocol/types.py +++ b/kafka/protocol/types.py @@ -5,6 +5,13 @@ from kafka.protocol.abstract import AbstractType +__all__ = [ + 'Int8', 'Int16', 'Int32', 'Int64', 'Float64', 'UnsignedVarInt32', 'VarInt32', 'VarInt64', + 'UUID', 'String', 'CompactString', 'Bytes', 'CompactBytes', 'Boolean', 'Schema', + 'Array', 'CompactArray', 'TaggedFields', 'BitField' +] + + def _pack(f, value): try: return f(value)