From 76ac4983f9f20beb4e2c6225bcb3d29df9e035e2 Mon Sep 17 00:00:00 2001
From: Soby Chacko <schacko@pivotal.io>
Date: Fri, 16 Mar 2018 17:33:14 -0400
Subject: [PATCH] Add ConditionalOnMissingBean on SchemaRegistryClient
 configuration

Resolves #1307
Resolves #1308
---
 .../client/config/SchemaRegistryClientConfiguration.java       | 3 +++
 1 file changed, 3 insertions(+)

diff --git a/spring-cloud-stream-schema/src/main/java/org/springframework/cloud/stream/schema/client/config/SchemaRegistryClientConfiguration.java b/spring-cloud-stream-schema/src/main/java/org/springframework/cloud/stream/schema/client/config/SchemaRegistryClientConfiguration.java
index e92606b30..77f6ad376 100644
--- a/spring-cloud-stream-schema/src/main/java/org/springframework/cloud/stream/schema/client/config/SchemaRegistryClientConfiguration.java
+++ b/spring-cloud-stream-schema/src/main/java/org/springframework/cloud/stream/schema/client/config/SchemaRegistryClientConfiguration.java
@@ -17,6 +17,7 @@
 package org.springframework.cloud.stream.schema.client.config;
 
 import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.boot.autoconfigure.condition.ConditionalOnMissingBean;
 import org.springframework.boot.context.properties.EnableConfigurationProperties;
 import org.springframework.cloud.stream.schema.client.CachingRegistryClient;
 import org.springframework.cloud.stream.schema.client.DefaultSchemaRegistryClient;
@@ -28,6 +29,7 @@ import org.springframework.util.StringUtils;
 /**
  * @author Marius Bogoevici
  * @author Vinicius Carvalho
+ * @author Soby Chacko
  */
 @Configuration
 @EnableConfigurationProperties(SchemaRegistryClientProperties.class)
@@ -37,6 +39,7 @@ public class SchemaRegistryClientConfiguration {
 	private SchemaRegistryClientProperties schemaRegistryClientProperties;
 
 	@Bean
+	@ConditionalOnMissingBean
 	public SchemaRegistryClient schemaRegistryClient() {
 		DefaultSchemaRegistryClient defaultSchemaRegistryClient = new DefaultSchemaRegistryClient();