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