Increase timeout for kafka topic creation (#5909)

open-telemetry · Apr 22, 2022 · a46e674 · a46e674
1 parent 2bb7873
commit a46e674
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/.../src/main/groovy/io/opentelemetry/instrumentation/kafkaclients/KafkaClientBaseTest.groovy b/.../src/main/groovy/io/opentelemetry/instrumentation/kafkaclients/KafkaClientBaseTest.groovy
@@ -54,7 +54,7 @@ abstract class KafkaClientBaseTest extends InstrumentationSpecification {
 
     // create test topic
     AdminClient.create(["bootstrap.servers": kafka.bootstrapServers]).withCloseable { admin ->
-      admin.createTopics([new NewTopic(SHARED_TOPIC, 1, (short) 1)]).all().get(10, TimeUnit.SECONDS)
+      admin.createTopics([new NewTopic(SHARED_TOPIC, 1, (short) 1)]).all().get(30, TimeUnit.SECONDS)
     }
 
     producer = new KafkaProducer<>(producerProps())