1 files changed, 13 insertions, 0 deletions
diff --git a/kafka/protocol/abstract.py b/kafka/protocol/abstract.py
new file mode 100644
index 0000000..9c53c8c
--- /dev/null
+++ b/kafka/protocol/abstract.py
@@ -0,0 +1,13 @@
+import abc
+
+
+class AbstractType(object):
+    __metaclass__ = abc.ABCMeta
+
+    @abc.abstractmethod
+    def encode(cls, value):
+        pass
+
+    @abc.abstractmethod
+    def decode(cls, data):
+        pass