mindol1004/spring-cloud-stream-binder-kafka
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

Fix NPE in Kafka Streams binder

Browse Source 
Resolves https://github.com/spring-cloud/spring-cloud-stream-binder-kafka/issues/981
This commit is contained in:
Soby Chacko
2020-11-05 12:34:59 -05:00
parent 73921db3ec
commit 23ce9e3d6e
1 changed files with 6 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

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

@@ -105,7 +105,9 @@ class KafkaStreamsBindingInformationCatalogue {
*/
void registerBindingProperties(KStream<?, ?> bindingTarget,
BindingProperties bindingProperties) {
this.bindingProperties.put(bindingTarget, bindingProperties);
if (bindingProperties != null) {
this.bindingProperties.put(bindingTarget, bindingProperties);
}
}
/**
@@ -115,7 +117,9 @@ class KafkaStreamsBindingInformationCatalogue {
*/
void registerConsumerProperties(KStream<?, ?> bindingTarget,
KafkaStreamsConsumerProperties kafkaStreamsConsumerProperties) {
this.consumerProperties.put(bindingTarget, kafkaStreamsConsumerProperties);
if (kafkaStreamsConsumerProperties != null) {
this.consumerProperties.put(bindingTarget, kafkaStreamsConsumerProperties);
}
}
/**