From 062bbc1cc36e92c6d5b8bfa2184d635a5648219f Mon Sep 17 00:00:00 2001 From: Soby Chacko Date: Fri, 1 Nov 2019 18:42:30 -0400 Subject: [PATCH] Add null check for KafkaStreamsBinderMetrics --- .../binder/kafka/streams/StreamsBuilderFactoryManager.java | 4 +++- 1 file changed, 3 insertions(+), 1 deletion(-) diff --git a/spring-cloud-stream-binder-kafka-streams/src/main/java/org/springframework/cloud/stream/binder/kafka/streams/StreamsBuilderFactoryManager.java b/spring-cloud-stream-binder-kafka-streams/src/main/java/org/springframework/cloud/stream/binder/kafka/streams/StreamsBuilderFactoryManager.java index c5ca7fcfe..036f90ec1 100644 --- a/spring-cloud-stream-binder-kafka-streams/src/main/java/org/springframework/cloud/stream/binder/kafka/streams/StreamsBuilderFactoryManager.java +++ b/spring-cloud-stream-binder-kafka-streams/src/main/java/org/springframework/cloud/stream/binder/kafka/streams/StreamsBuilderFactoryManager.java @@ -74,7 +74,9 @@ class StreamsBuilderFactoryManager implements SmartLifecycle { streamsBuilderFactoryBean.start(); this.kafkaStreamsRegistry.registerKafkaStreams(streamsBuilderFactoryBean); } - this.kafkaStreamsBinderMetrics.addMetrics(streamsBuilderFactoryBeans); + if (this.kafkaStreamsBinderMetrics != null) { + this.kafkaStreamsBinderMetrics.addMetrics(streamsBuilderFactoryBeans); + } this.running = true; } catch (Exception ex) {