summaryrefslogtreecommitdiff
diff options
context:
space:
mode:
authorTaras Voinarovskyi <voyn1991@gmail.com>2020-03-19 20:15:21 +0200
committerTaras Voinarovskyi <voyn1991@gmail.com>2020-03-19 20:15:21 +0200
commit8a72f1a567c4d71dc6a412f3d41ad80f56c495ed (patch)
tree009f5713051308e59a3721fe8f4870ae25c316c1
parent5d4b3ec4d6773740a036edb4103294a503a2a421 (diff)
downloadkafka-python-add_new_api_versions.tar.gz
Add API version determination code for newer kafka brokersadd_new_api_versions
-rw-r--r--kafka/conn.py5
1 files changed, 5 insertions, 0 deletions
diff --git a/kafka/conn.py b/kafka/conn.py
index c383123..797928d 100644
--- a/kafka/conn.py
+++ b/kafka/conn.py
@@ -26,6 +26,7 @@ from kafka.metrics.stats import Avg, Count, Max, Rate
from kafka.oauth.abstract import AbstractTokenProvider
from kafka.protocol.admin import SaslHandShakeRequest
from kafka.protocol.commit import OffsetFetchRequest
+from kafka.protocol.fetch import FetchRequest
from kafka.protocol.metadata import MetadataRequest
from kafka.protocol.parser import KafkaProtocol
from kafka.protocol.types import Int32, Int8
@@ -1166,6 +1167,10 @@ class BrokerConnection(object):
# in reverse order. As soon as we find one that works, return it
test_cases = [
# format (<broker version>, <needed struct>)
+ ((2, 3, 0), FetchRequest[0].API_KEY, 11),
+ ((2, 1, 0), MetadataRequest[0].API_KEY, 7),
+ ((2, 0, 0), FetchRequest[0].API_KEY, 8),
+ ((1, 1, 0), FetchRequest[0].API_KEY, 7),
((1, 0, 0), MetadataRequest[5]),
((0, 11, 0), MetadataRequest[4]),
((0, 10, 2), OffsetFetchRequest[2]),