Implement PR change requests: fewer versions for travis testing, remo…

…ve unused older versions for inference code, remove one minor version from known server list

.travis.yml

@@ -14,10 +14,6 @@ env:
     - KAFKA_VERSION=0.10.2.2
     - KAFKA_VERSION=0.11.0.3
     - KAFKA_VERSION=1.1.1
-    - KAFKA_VERSION=2.0.1
-    - KAFKA_VERSION=2.1.1
-    - KAFKA_VERSION=2.2.0
-    - KAFKA_VERSION=2.3.0
     - KAFKA_VERSION=2.4.0
     - KAFKA_VERSION=2.5.0
 

build_integration.sh

@@ -1,6 +1,6 @@
 #!/bin/bash
 
-: ${ALL_RELEASES:="0.8.2.2 0.9.0.1 0.10.1.1 0.10.2.2 0.11.0.3 1.0.2 1.1.1 2.0.1 2.1.1 2.2.0 2.2.1 2.3.0 2.4.0 2.5.0"}
+: ${ALL_RELEASES:="0.8.2.2 0.9.0.1 0.10.1.1 0.10.2.2 0.11.0.3 1.0.2 1.1.1 2.0.1 2.1.1 2.2.1 2.3.0 2.4.0 2.5.0"}
 : ${SCALA_VERSION:=2.11}
 : ${DIST_BASE_URL:=https://archive.apache.org/dist/kafka/}
 : ${KAFKA_SRC_GIT:=https://github.com/apache/kafka.git}

kafka/conn.py

@@ -1180,10 +1180,6 @@ def _infer_broker_version_from_api_versions(self, api_versions):
             ((0, 11, 0), MetadataRequest[4]),
             ((0, 10, 2), OffsetFetchRequest[2]),
             ((0, 10, 1), MetadataRequest[2]),
-            # taken from https://github.com/edenhill/librdkafka/blob/master/src/rdkafka_feature.c#L234
-            ((0, 9, 0), ProduceRequest[1]),
-            ((0, 8, 2), OffsetFetchRequest[1]),
-            ((0, 8, 1), OffsetFetchRequest[0]),
         ]
 
         # Get the best match of test cases