diff --git a/instrumentation/kafka-clients/kafka-clients-0.11/testing/src/main/groovy/io/opentelemetry/instrumentation/kafkaclients/KafkaClientBaseTest.groovy b/instrumentation/kafka-clients/kafka-clients-0.11/testing/src/main/groovy/io/opentelemetry/instrumentation/kafkaclients/KafkaClientBaseTest.groovy index d91a90883d..f97c3571d2 100644 --- a/instrumentation/kafka-clients/kafka-clients-0.11/testing/src/main/groovy/io/opentelemetry/instrumentation/kafkaclients/KafkaClientBaseTest.groovy +++ b/instrumentation/kafka-clients/kafka-clients-0.11/testing/src/main/groovy/io/opentelemetry/instrumentation/kafkaclients/KafkaClientBaseTest.groovy @@ -29,13 +29,13 @@ abstract class KafkaClientBaseTest extends InstrumentationSpecification { protected static final SHARED_TOPIC = "shared.topic" @Shared - static KafkaContainer kafka + KafkaContainer kafka @Shared - static Producer producer + Producer producer @Shared - static Consumer consumer + Consumer consumer @Shared - static CountDownLatch consumerReady = new CountDownLatch(1) + CountDownLatch consumerReady = new CountDownLatch(1) static TopicPartition topicPartition = new TopicPartition(SHARED_TOPIC, 0) @@ -97,7 +97,7 @@ abstract class KafkaClientBaseTest extends InstrumentationSpecification { } // Kafka's eventual consistency behavior forces us to do a couple of empty poll() calls until it gets properly assigned a topic partition - static void awaitUntilConsumerIsReady() { + void awaitUntilConsumerIsReady() { if (consumerReady.await(0, TimeUnit.SECONDS)) { return }