Skip to content

Commit ec6721b

Browse files
committed
fix error
1 parent 3d4a4b9 commit ec6721b

File tree

1 file changed

+1
-0
lines changed
  • instrumentation/kafka/kafka-streams-0.11/javaagent/src/test/java/io/opentelemetry/javaagent/instrumentation/kafkastreams

1 file changed

+1
-0
lines changed

instrumentation/kafka/kafka-streams-0.11/javaagent/src/test/java/io/opentelemetry/javaagent/instrumentation/kafkastreams/KafkaStreamsBaseTest.java

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -136,6 +136,7 @@ static Map<String, Object> producerProps(String servers) {
136136

137137
// Kafka's eventual consistency behavior forces us to do a couple of empty poll() calls until it
138138
// gets properly assigned a topic partition
139+
@SuppressWarnings("PreferJavaTimeOverload")
139140
static void awaitUntilConsumerIsReady() throws InterruptedException {
140141
if (consumerReady.await(0, TimeUnit.SECONDS)) {
141142
return;

0 commit comments

Comments
 (0)