We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent e918672 commit 2e21b3bCopy full SHA for 2e21b3b
pulsar-client/src/main/java/org/apache/pulsar/client/impl/tracing/OpenTelemetryProducerInterceptor.java
@@ -61,8 +61,7 @@ public OpenTelemetryProducerInterceptor() {
61
* This is called lazily on the first message.
62
*/
63
private void initializeIfNeeded(Producer producer) {
64
- if (!initialized && producer instanceof ProducerBase) {
65
- ProducerBase<?> producerBase = (ProducerBase<?>) producer;
+ if (!initialized && producer instanceof ProducerBase<?> producerBase) {
66
PulsarClientImpl client = producerBase.getClient();
67
InstrumentProvider instrumentProvider = client.instrumentProvider();
68
0 commit comments