From a2baf7ecea3038e60baf4823f41a4f9e8bf30ec4 Mon Sep 17 00:00:00 2001
From: kwall <kwall@apache.org>
Date: Mon, 4 Jul 2022 18:56:50 +0100
Subject: [PATCH 1/2] experiment - fixing flakey tests

---
 pom.xml                                                        | 2 ++
 .../io/bf2/kafka/authorizer/CustomAclAuthorizerTest.properties | 3 +++
 2 files changed, 5 insertions(+)

diff --git a/pom.xml b/pom.xml
index 264b5ce..78debb5 100644
--- a/pom.xml
+++ b/pom.xml
@@ -143,6 +143,8 @@
                 <artifactId>maven-surefire-plugin</artifactId>
                 <configuration>
                     <redirectTestOutputToFile>true</redirectTestOutputToFile>
+                    <useUnlimitedThreads>false</useUnlimitedThreads>
+                    <forkCount>1</forkCount>
                 </configuration>
             </plugin>
             <plugin>
diff --git a/src/test/resources/io/bf2/kafka/authorizer/CustomAclAuthorizerTest.properties b/src/test/resources/io/bf2/kafka/authorizer/CustomAclAuthorizerTest.properties
index 792e2d3..3956148 100644
--- a/src/test/resources/io/bf2/kafka/authorizer/CustomAclAuthorizerTest.properties
+++ b/src/test/resources/io/bf2/kafka/authorizer/CustomAclAuthorizerTest.properties
@@ -40,3 +40,6 @@ kas.authorizer.acl.logging.006=topic=important_topic;level=WARN
 kas.policy.shared-admin.adminclient-listener.name=controlplane
 kas.policy.shared-admin.adminclient-listener.port=9090
 kas.policy.shared-admin.adminclient-listener.protocol=PLAINTEXT
+
+# Override suppression window (tests control use explicit invalidation)
+kas.authorizer.acl.logging.suppressionWindow.duration=PT5M

From 602ae0230ce4abb0aa5ad8fe59b98b127c43af72 Mon Sep 17 00:00:00 2001
From: kwall <kwall@apache.org>
Date: Mon, 4 Jul 2022 19:12:21 +0100
Subject: [PATCH 2/2] test fix - fix partition counter leak

---
 .../io/bf2/kafka/topic/ManagedKafkaCreateTopicPolicyTest.java    | 1 +
 1 file changed, 1 insertion(+)

diff --git a/src/test/java/io/bf2/kafka/topic/ManagedKafkaCreateTopicPolicyTest.java b/src/test/java/io/bf2/kafka/topic/ManagedKafkaCreateTopicPolicyTest.java
index f74ede0..cb3e7b6 100644
--- a/src/test/java/io/bf2/kafka/topic/ManagedKafkaCreateTopicPolicyTest.java
+++ b/src/test/java/io/bf2/kafka/topic/ManagedKafkaCreateTopicPolicyTest.java
@@ -58,6 +58,7 @@ void setup() {
     @AfterEach
     void tearDown() {
         policy.close();
+        disabledPolicy.close();
     }
 
     @Test