Skip to content

Commit f4e568a

Browse files
Copilottrask
andcommitted
Use import instead of FQCN for Supplier in test
Co-authored-by: trask <[email protected]>
1 parent 5419f03 commit f4e568a

File tree

1 file changed

+3
-2
lines changed

1 file changed

+3
-2
lines changed

instrumentation/kafka/kafka-clients/kafka-clients-2.6/library/src/test/java/io/opentelemetry/instrumentation/kafkaclients/v2_6/KafkaTelemetryInterceptorTest.java

Lines changed: 3 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -20,6 +20,7 @@
2020
import java.io.ObjectStreamClass;
2121
import java.util.HashMap;
2222
import java.util.Map;
23+
import java.util.function.Supplier;
2324
import org.apache.kafka.clients.consumer.ConsumerConfig;
2425
import org.apache.kafka.clients.consumer.KafkaConsumer;
2526
import org.apache.kafka.clients.producer.KafkaProducer;
@@ -78,7 +79,7 @@ void badProducerConfig() {
7879
Map<String, Object> producerConfig = producerConfig();
7980
producerConfig.put(
8081
TracingProducerInterceptor.CONFIG_KEY_KAFKA_TELEMETRY_SUPPLIER,
81-
(java.util.function.Supplier<?>) () -> "not a KafkaTelemetry");
82+
(Supplier<?>) () -> "not a KafkaTelemetry");
8283
new KafkaProducer<>(producerConfig).close();
8384
})
8485
.hasRootCauseInstanceOf(IllegalStateException.class)
@@ -108,7 +109,7 @@ void badConsumerConfig() {
108109
Map<String, Object> consumerConfig = consumerConfig();
109110
consumerConfig.put(
110111
TracingConsumerInterceptor.CONFIG_KEY_KAFKA_TELEMETRY_SUPPLIER,
111-
(java.util.function.Supplier<?>) () -> "not a KafkaTelemetry");
112+
(Supplier<?>) () -> "not a KafkaTelemetry");
112113
new KafkaConsumer<>(consumerConfig).close();
113114
})
114115
.hasRootCauseInstanceOf(IllegalStateException.class)

0 commit comments

Comments
 (0)