如何将AVRO消息发布订阅与rabbitmq云流绑定器集成?

5cnsuln7  于 2022-12-18  发布在  RabbitMQ
关注(0)|答案(1)|浏览(192)

我尝试将rabbitmq binder与spring cloud stream集成,但没有找到任何属性,也不确定Avro消息转换器的使用部分。

spring:
  config:
    activate:
      on-profile: rabbit
  cloud:
    stream:
      input-bindings:
        contentType: application/*+avro
      default-binder: rabbit
      bindings:
        messagePublisher-out-0:
          binder: rabbit
        messageSubscriber-in-0:
          binder: rabbit

上面的东西是不工作,它是给警告,contentType是未知的属性,因为我试图创建bean如下,以及,
我使用的是2.7.6的Spring Boot 版本,版本与JDK 8相同。

@Bean
public MessageConverter jsonMessageConverter() {
    or may be not sure not able to plug AvroSchemaMessageConverter here...
}
6xfqseft

6xfqseft1#

您可以使用或扩展ByteArrayMessageConverter,并使用Avro自己的BinaryEncoder类返回具有byte[]内容的Message类型。
对于任何二进制内容(如Avro),类型都是application/octet-stream

相关问题