Skip to content

Commit 3d4a4b9

Browse files
committed
fix errorprone
1 parent 340a942 commit 3d4a4b9

File tree

2 files changed

+2
-0
lines changed

2 files changed

+2
-0
lines changed

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

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -83,6 +83,7 @@ void testKafkaProduceAndConsumeWithStreamsInBetween()
8383
KafkaStreamsBaseTest.producer.send(new ProducerRecord<>(STREAM_PENDING, 10, greeting));
8484

8585
awaitUntilConsumerIsReady();
86+
@SuppressWarnings("PreferJavaTimeOverload")
8687
ConsumerRecords<Integer, String> records =
8788
KafkaStreamsBaseTest.consumer.poll(Duration.ofSeconds(10).toMillis());
8889
Headers receivedHeaders = null;

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

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -80,6 +80,7 @@ void testKafkaProduceAndConsumeWithStreamsInBetween()
8080
KafkaStreamsBaseTest.producer.send(new ProducerRecord<>(STREAM_PENDING, 10, greeting));
8181

8282
// check that the message was received
83+
@SuppressWarnings("PreferJavaTimeOverload")
8384
ConsumerRecords<Integer, String> records =
8485
KafkaStreamsBaseTest.consumer.poll(Duration.ofSeconds(10).toMillis());
8586
Headers receivedHeaders = null;

0 commit comments

Comments
 (0)