librdkafka and confluent-kafka-python v2.3.0rc3 (#1656)

.semaphore/semaphore.yml

@@ -8,7 +8,7 @@ execution_time_limit:
 global_job_config:
   env_vars:
     - name: LIBRDKAFKA_VERSION
-      value: v2.2.0
+      value: v2.3.0-RC3
   prologue:
     commands:
       - checkout

docs/conf.py

@@ -35,7 +35,7 @@
 # built documents.
 #
 # The short X.Y version.
-version = '2.2.0'
+version = '2.3.0rc3'
 # The full version, including alpha/beta/rc tags.
 release = version
 ######################################################################

examples/docker/Dockerfile.alpine

@@ -30,7 +30,7 @@ FROM alpine:3.12
 
 COPY . /usr/src/confluent-kafka-python
 
-ENV LIBRDKAFKA_VERSION v2.2.0
+ENV LIBRDKAFKA_VERSION v2.3.0-RC3
 ENV KAFKACAT_VERSION master
 
 

setup.py

@@ -75,7 +75,7 @@ def get_install_requirements(path):
 setup(name='confluent-kafka',
       # Make sure to bump CFL_VERSION* in confluent_kafka/src/confluent_kafka.h
       # and version in docs/conf.py.
-      version='2.2.0',
+      version='2.3.0rc3',
       description='Confluent\'s Python client for Apache Kafka',
       author='Confluent Inc',
       author_email='support@confluent.io',

src/confluent_kafka/_util/conversion_util.py

@@ -21,18 +21,18 @@ def convert_to_enum(val, enum_clazz):
         if type(enum_clazz) is not type(Enum):
             raise TypeError("'enum_clazz' must be of type Enum")
 
-        if type(val) == str:
+        if isinstance(val, str):
             # Allow it to be specified as case-insensitive string, for convenience.
             try:
                 val = enum_clazz[val.upper()]
             except KeyError:
                 raise ValueError("Unknown value \"%s\": should be a %s" % (val, enum_clazz.__name__))
 
-        elif type(val) == int:
+        elif isinstance(val, int):
             # The C-code passes restype as an int, convert to enum.
             val = enum_clazz(val)
 
-        elif type(val) != enum_clazz:
+        elif not isinstance(val, enum_clazz):
             raise TypeError("Unknown value \"%s\": should be a %s" % (val, enum_clazz.__name__))
 
         return val

src/confluent_kafka/admin/_config.py

@@ -146,14 +146,14 @@ def __init__(self, restype, name,
         if name is None:
             raise ValueError("Expected resource name to be a string")
 
-        if type(restype) == str:
+        if isinstance(restype, str):
             # Allow resource type to be specified as case-insensitive string, for convenience.
             try:
                 restype = ConfigResource.Type[restype.upper()]
             except KeyError:
                 raise ValueError("Unknown resource type \"%s\": should be a ConfigResource.Type" % restype)
 
-        elif type(restype) == int:
+        elif isinstance(restype, int):
             # The C-code passes restype as an int, convert to Type.
             restype = ConfigResource.Type(restype)
 

src/confluent_kafka/src/confluent_kafka.h

@@ -42,28 +42,28 @@
  *  0xMMmmRRPP
  *  MM=major, mm=minor, RR=revision, PP=patchlevel (not used)
  */
-#define CFL_VERSION     0x02020000
-#define CFL_VERSION_STR "2.2.0"
+#define CFL_VERSION     0x02030000
+#define CFL_VERSION_STR "2.3.0rc3"
 
 /**
  * Minimum required librdkafka version. This is checked both during
  * build-time (just below) and runtime (see confluent_kafka.c).
  * Make sure to keep the MIN_RD_KAFKA_VERSION, MIN_VER_ERRSTR and #error
  * defines and strings in sync.
  */
-#define MIN_RD_KAFKA_VERSION 0x020200ff
+#define MIN_RD_KAFKA_VERSION 0x020300ff
 
 #ifdef __APPLE__
-#define MIN_VER_ERRSTR "confluent-kafka-python requires librdkafka v2.2.0 or later. Install the latest version of librdkafka from Homebrew by running `brew install librdkafka` or `brew upgrade librdkafka`"
+#define MIN_VER_ERRSTR "confluent-kafka-python requires librdkafka v2.3.0 or later. Install the latest version of librdkafka from Homebrew by running `brew install librdkafka` or `brew upgrade librdkafka`"
 #else
-#define MIN_VER_ERRSTR "confluent-kafka-python requires librdkafka v2.2.0 or later. Install the latest version of librdkafka from the Confluent repositories, see http://docs.confluent.io/current/installation.html"
+#define MIN_VER_ERRSTR "confluent-kafka-python requires librdkafka v2.3.0 or later. Install the latest version of librdkafka from the Confluent repositories, see http://docs.confluent.io/current/installation.html"
 #endif
 
 #if RD_KAFKA_VERSION < MIN_RD_KAFKA_VERSION
 #ifdef __APPLE__
-#error "confluent-kafka-python requires librdkafka v2.2.0 or later. Install the latest version of librdkafka from Homebrew by running `brew install librdkafka` or `brew upgrade librdkafka`"
+#error "confluent-kafka-python requires librdkafka v2.3.0 or later. Install the latest version of librdkafka from Homebrew by running `brew install librdkafka` or `brew upgrade librdkafka`"
 #else
-#error "confluent-kafka-python requires librdkafka v2.2.0 or later. Install the latest version of librdkafka from the Confluent repositories, see http://docs.confluent.io/current/installation.html"
+#error "confluent-kafka-python requires librdkafka v2.3.0 or later. Install the latest version of librdkafka from the Confluent repositories, see http://docs.confluent.io/current/installation.html"
 #endif
 #endif
 

tests/integration/admin/test_incremental_alter_configs.py

@@ -1,5 +1,5 @@
-from confluent_kafka.admin import ConfigResource,\
-    ConfigEntry, ResourceType,\
+from confluent_kafka.admin import ConfigResource, \
+    ConfigEntry, ResourceType, \
     AlterConfigOpType
 
 

tests/test_Consumer.py

@@ -185,7 +185,7 @@ def commit_cb(cs, err, ps):
 def test_subclassing():
     class SubConsumer(Consumer):
         def poll(self, somearg):
-            assert type(somearg) == str
+            assert isinstance(somearg, str)
             super(SubConsumer, self).poll(timeout=0.0001)
 
     sc = SubConsumer({"group.id": "test", "session.timeout.ms": "90"})

tests/test_Producer.py

@@ -134,7 +134,7 @@ def produce_hi(self):
             super(SubProducer, self).produce(self.topic, value='hi')
 
     sp = SubProducer(dict(), 'atopic')
-    assert type(sp) == SubProducer
+    assert isinstance(sp, SubProducer)
 
     # Invalid config should fail
     with pytest.raises(KafkaException):