title: How to use Spring Cloud Stream Kafka with Confluent Schema Registry?
body: <p>I am seeking a simple workable example which use Spring Cloud Stream Kafka with Confluent Schema Registry (producer &amp; consumer). I followed the <a href="https://docs.spring.io/spring-cloud-stream/docs/Ditmars.BUILD-SNAPSHOT/reference/htmlsingle/#_using_confluent_s_schema_registry" rel="nofollow noreferrer" title="reference guide">spring cloud stream reference guide</a> by adding the following code but it didn't work. Can anyone guide me how to achieve it? Many thanks!</p>
  
  <pre><code>@Bean
  public SchemaRegistryClient schemaRegistryClient(@Value("${spring.cloud.stream.schemaRegistryClient.endpoint}") String endpoint){
    ConfluentSchemaRegistryClient client = new ConfluentSchemaRegistryClient();
    client.setEndpoint(endpoint);
    return client;
  }
  </code></pre>