diff options
| author | Dana Powers <dana.powers@rd.io> | 2015-12-09 15:17:52 -0800 |
|---|---|---|
| committer | Dana Powers <dana.powers@rd.io> | 2015-12-09 15:17:52 -0800 |
| commit | 9740b2b88b41726f143b3367285dbc118bfa0a8a (patch) | |
| tree | d497d25d88a85daf47c75aa1aa575f48fe05322d /kafka/protocol/message.py | |
| parent | 1636c96df41b61b37883a60238dfb42b353f36a2 (diff) | |
| download | kafka-python-9740b2b88b41726f143b3367285dbc118bfa0a8a.tar.gz | |
Support pickling of Structs -- _encode_self instance method needs some magic
Diffstat (limited to 'kafka/protocol/message.py')
| -rw-r--r-- | kafka/protocol/message.py | 1 |
1 files changed, 1 insertions, 0 deletions
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 |