debug

orange-kao · orange-kao · commit e7e22fd865e2 · 2024-08-13T03:32:06.000Z
diff --git a/test/service.py b/test/service.py
@@ -126,7 +126,7 @@ def wait_for(self, pattern, timeout=30):
         while True:
             if not self.is_alive():
                 self.join()
-                #raise RuntimeError("Child thread died already.")
+                raise RuntimeError("Child thread died already.")
 
             elapsed = time.time() - start
             if elapsed >= timeout:
diff --git a/test/test_admin_integration.py b/test/test_admin_integration.py
@@ -126,14 +126,37 @@ def test_describe_configs_mixed_resources_returns_configs(topic, kafka_admin_cli
         ConfigResource(ConfigResourceType.BROKER, broker_id)])
 
     assert len(configs) == 2
+    retry = False
 
+    for config in configs:
+        assert (config.resources[0][2] == ConfigResourceType.TOPIC
+                and config.resources[0][3] == topic) or \
+               (config.resources[0][2] == ConfigResourceType.BROKER
+                and config.resources[0][3] == str(broker_id))
+        #assert len(config.resources[0][4]) > 1
+        if not (len(config.resources[0][4]) > 1):
+            retry = True
+
+    if not retry:
+        return
+
+    sleep(10)
+
+    broker_id = kafka_admin_client._client.cluster._brokers[0].nodeId
+    configs = kafka_admin_client.describe_configs([
+        ConfigResource(ConfigResourceType.TOPIC, topic),
+        ConfigResource(ConfigResourceType.BROKER, broker_id)])
+
+    assert len(configs) == 2
     for config in configs:
         assert (config.resources[0][2] == ConfigResourceType.TOPIC
                 and config.resources[0][3] == topic) or \
                (config.resources[0][2] == ConfigResourceType.BROKER
                 and config.resources[0][3] == str(broker_id))
         assert len(config.resources[0][4]) > 1
 
+    assert False
+
 
 @pytest.mark.skipif(env_kafka_version() < (0, 11), reason="Describe config features require broker >=0.11")
 def test_describe_configs_invalid_broker_id_raises(kafka_admin_client):
diff --git a/test/test_consumer_group.py b/test/test_consumer_group.py
@@ -34,7 +34,7 @@ def test_consumer(kafka_broker, topic):
 def test_consumer_topics(kafka_broker, topic):
     consumer = KafkaConsumer(bootstrap_servers=get_connect_str(kafka_broker))
     # Necessary to drive the IO
-    consumer.poll(500)
+    consumer.poll(5000)
     assert topic in consumer.topics()
     assert len(consumer.partitions_for_topic(topic)) > 0
     consumer.close()
diff --git a/tox.ini b/tox.ini
@@ -2,7 +2,8 @@
 envlist = py312
 
 [pytest]
-testpaths = test/test_ssl_integration.py
+#testpaths = test/test_ssl_integration.py
+testpaths = test
 addopts = --durations=10
 log_format = %(created)f %(filename)-23s %(threadName)s %(message)s
 
@@ -25,11 +26,11 @@ deps =
     crc32c
     botocore
 commands =
-    pytest {posargs:--cov=kafka -vvv --tb=long --capture=sys --show-capture=all --log-level=notset --log-cli-level=notset --log-file-level=notset}
+    pytest {posargs:--cov=kafka -vvv -x --junitxml=junit.xml --tb=long --capture=sys --show-capture=all --log-level=notset --log-cli-level=notset --log-file-level=notset}
 setenv =
     CRC32C_SW_MODE = auto
     PROJECT_ROOT = {toxinidir}
-    RETRY_TIMEOUT_MULTIPLIER = 8
-    MAX_TIMEOUT_MULTIPLIER = 8
+    RETRY_TIMEOUT_MULTIPLIER = 1024
+    MAX_TIMEOUT_MULTIPLIER = 1024
 passenv = KAFKA_VERSION
 
