Add Kafka 2.6.0 to tests and protocol compatibility matrix (#2162)

* Co-authored-by: Andrew Brown <andrew.brown@shopify.com>
* Co-authored-by: Aaron Brady <aaron.brady@shopify.com>

1 files changed, 13 insertions, 0 deletions

diff --git a/kafka/protocol/types.py b/kafka/protocol/types.py
index d508b26..ade1bc6 100644
--- a/kafka/protocol/types.py
+++ b/kafka/protocol/types.py
@@ -77,6 +77,19 @@ class Int64(AbstractType):
         return _unpack(cls._unpack, data.read(8))
 
 
+class Float64(AbstractType):
+    _pack = struct.Struct('>d').pack
+    _unpack = struct.Struct('>d').unpack
+
+    @classmethod
+    def encode(cls, value):
+        return _pack(cls._pack, value)
+
+    @classmethod
+    def decode(cls, data):
+        return _unpack(cls._unpack, data.read(8))
+
+
 class String(AbstractType):
     def __init__(self, encoding='utf-8'):
         self.encoding = encoding