Skip to content

Commit ced0922

Browse files
committed
return when kafkaconsumer metrics are null
1 parent 9ad5da0 commit ced0922

File tree

1 file changed

+2
-1
lines changed

1 file changed

+2
-1
lines changed

psc/src/main/java/com/pinterest/psc/consumer/kafka/PscKafkaConsumer.java

+2-1
Original file line numberDiff line numberDiff line change
@@ -107,7 +107,8 @@ public void initializeBackend(ServiceDiscoveryConfig discoveryConfig, TopicUri t
107107

108108
@Override
109109
protected synchronized void reportConsumerMetrics() {
110-
if (kafkaConsumer == null)
110+
// temporary fix to avoid NPE in KafkaConsumer.metrics()
111+
if (kafkaConsumer == null || kafkaConsumer.metrics() == null)
111112
return;
112113

113114
Map<org.apache.kafka.common.MetricName, ? extends org.apache.kafka.common.Metric> kafkaMetrics = kafkaConsumer.metrics();

0 commit comments

Comments
 (0)