如何将Spring Cloud Stream Kafka与Confluent Schema Registry一起使用？

Question

我正在寻找一个简单可行的示例，该示例使用Spring Cloud Stream Kafka和Confluent Schema Registry（producer

@Bean
public SchemaRegistryClient schemaRegistryClient(@Value("${spring.cloud.stream.schemaRegistryClient.endpoint}") String endpoint){
  ConfluentSchemaRegistryClient client = new ConfluentSchemaRegistryClient();
  client.setEndpoint(endpoint);
  return client;
}

Answer 1

这是一个简单的示例，显示带有Avro序列化的Spring Cloud stream。此示例存根并模拟模式注册表。

您的bean看起来是正确的，您只需要为应用程序中的“spring.cloud.stream.schemaRegistryClient.endpoint”运行模式注册表和配置。属性（或application.yml）

Answer 2

我尝试了这个模式注册表示例，它对我有效。自述文件中提到了所有说明。