Spring云流Avro

Question

我无法使用功能供应商发送Avro消息。SCSt尝试将消息作为JSON发送，但失败。有人能指出是否需要任何其他配置吗？

这是供应商的功能bean

@Bean
public Supplier<Sensor> supplier() {
    Random random = new Random();
    return () -> Sensor.newBuilder()
        .setId("id")
        .setTemperature(random.nextFloat())
        .setAcceleration(random.nextFloat())
        .setVelocity(random.nextFloat())
        .build();
}

和配置

spring:
  cloud:
    schema-registry-client:
      endpoint: http://localhost:8990
    schema:
      avro:
        schema-locations: classpath:avro/sensor.avsc
    stream:
      function:
        definition: supplier
        bindings:
          supplier-out-0: sensor
      bindings:
        sensor:
          destination: sensor-exchange
          group: sensor-queue
          content-type: application/*+avro

Answer 1

这是由于转换发生的问题。我在Spring Cloud Function中提交了一个问题：https://github.com/spring-cloud/spring-cloud-function/issues/611

作为一种解决方法，您可以将内容类型用作：spring。云流动绑定。。。内容类型：应用程序/avro，在生产者配置中没有通配符类型。当上述问题得到解决后，您可以继续使用包含通配符的内容类型（application/*avro）。很抱歉给您带来不便。

我更新了此示例以反映此解决方案，当我们得到适当的修复时，将恢复此解决方案。

更新：Spring云函数中的问题在3.0中得到了解决。x分支。请使用以下依赖项获取修复。

 <dependency>
    <groupId>org.springframework.cloud</groupId>
    <artifactId>spring-cloud-function-context</artifactId>
    <version>3.0.12.BUILD-SNAPSHOT</version>
</dependency>

有了这个，您可以在内容类型中使用通配符类型：Application/*avro。

<代码>3.0.12。该版本将于下周发布。