SpringCloud/spring-cloud-stream
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

Add null check for KafkaStreamsBinderMetrics

Browse Source
This commit is contained in:
Soby Chacko
2019-11-01 18:42:30 -04:00
parent bc1936eb28
commit 062bbc1cc3
1 changed files with 3 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

4
spring-cloud-stream-binder-kafka-streams/src/main/java/org/springframework/cloud/stream/binder/kafka/streams/StreamsBuilderFactoryManager.java
View File

@@ -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) {