From 9740b2b88b41726f143b3367285dbc118bfa0a8a Mon Sep 17 00:00:00 2001 From: Dana Powers Date: Wed, 9 Dec 2015 15:17:52 -0800 Subject: Support pickling of Structs -- _encode_self instance method needs some magic --- kafka/protocol/message.py | 1 + 1 file changed, 1 insertion(+) (limited to 'kafka/protocol/message.py') diff --git a/kafka/protocol/message.py b/kafka/protocol/message.py index cd5d274..a67d7f5 100644 --- a/kafka/protocol/message.py +++ b/kafka/protocol/message.py @@ -1,5 +1,6 @@ import io +from . import pickle from .struct import Struct from .types import ( Int8, Int32, Int64, Bytes, Schema, AbstractType -- cgit v1.2.1