Bump confluent-kafka to 2.11.0

Author: gwaramadze

conda/post-link.sh

@@ -6,7 +6,7 @@ $PREFIX/bin/pip install \
 'influxdb3-python[pandas]>=0.7,<1.0' \
 'pyiceberg[pyarrow,glue]>=0.7' \
 'redis[hiredis]>=5.2.0,<6' \
-'confluent-kafka[avro,json,protobuf,schemaregistry]>=2.8.2,<2.11' \
+'confluent-kafka[avro,json,protobuf,schemaregistry]>=2.8.2,<2.12' \
 'influxdb>=5.3,<6' \
 'jsonpath_ng>=1.7.0,<2' \
 'types-psycopg2>=2.9,<3'

requirements.txt

@@ -1,4 +1,4 @@
-confluent-kafka[avro,json,protobuf,schemaregistry]>=2.8.2,<2.11
+confluent-kafka[avro,json,protobuf,schemaregistry]>=2.8.2,<2.12
 requests>=2.32
 rocksdict>=0.3,<0.4
 typing_extensions>=4.8

tests/test_quixstreams/test_kafka/test_consumer.py

@@ -70,7 +70,10 @@ def test_consumer_subscribe_topic_doesnt_exist(self, consumer):
 
         with consumer:
             consumer.subscribe(topics=[topic_name])
+            start_time = time.time()
             msg = consumer.poll(timeout=3)
+            elapsed_time = time.time() - start_time
+            print(f"Poll operation took {elapsed_time:.3f} seconds")
             assert msg
             err = msg.error()
             assert err.code() == KafkaError.UNKNOWN_TOPIC_OR_PART