Fix Sonar Issue

garyrussell · garyrussell · commit ac7ab707a790 · 2020-06-22T13:40:33.000-04:00
diff --git a/spring-kafka/src/main/java/org/springframework/kafka/config/StreamsBuilderFactoryBean.java b/spring-kafka/src/main/java/org/springframework/kafka/config/StreamsBuilderFactoryBean.java
@@ -240,7 +240,7 @@ public int getPhase() {
 	 * may be null if this {@link StreamsBuilderFactoryBean} hasn't been started.
 	 * @since 1.1.4
 	 */
-	public KafkaStreams getKafkaStreams() {
+	public synchronized KafkaStreams getKafkaStreams() {
 		return this.kafkaStreams;
 	}
 

Original file line number	Diff line number	Diff line change
`@@ -240,7 +240,7 @@ public int getPhase() {`
`240`	`240`	`* may be null if this {@link StreamsBuilderFactoryBean} hasn't been started.`
`241`	`241`	`* @since 1.1.4`
`242`	`242`	`*/`
`243`		`- public KafkaStreams getKafkaStreams() {`
	`243`	`+ public synchronized KafkaStreams getKafkaStreams() {`
`244`	`244`	`return this.kafkaStreams;`
`245`	`245`	`}`
`246`	`246`