try fix thread leak

Signed-off-by: Yupeng Fu <[email protected]>
opensearch-project · Jan 19, 2025 · 8e7af9c · 8e7af9c
1 parent 88e27f6
commit 8e7af9c
Showing 1 changed file with 3 additions and 0 deletions.
diff --git a/...ion-kafka/src/internalClusterTest/java/org/opensearch/plugin/kafka/IngestFromKafkaIT.java b/...ion-kafka/src/internalClusterTest/java/org/opensearch/plugin/kafka/IngestFromKafkaIT.java
@@ -8,6 +8,8 @@
 
 package org.opensearch.plugin.kafka;
 
+import com.carrotsearch.randomizedtesting.annotations.ThreadLeakLingering;
+
 import org.apache.kafka.clients.producer.KafkaProducer;
 import org.apache.kafka.clients.producer.Producer;
 import org.apache.kafka.clients.producer.ProducerRecord;
@@ -43,6 +45,7 @@
 /**
  * Integration test for Kafka ingestion
  */
+@ThreadLeakLingering(linger = 5000) // wait for container pull thread to die
 public class IngestFromKafkaIT extends OpenSearchIntegTestCase {
     static final String topicName = "test";