我尝试将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...
}
1条答案
按热度按时间6xfqseft1#
您可以使用或扩展
ByteArrayMessageConverter
,并使用Avro自己的BinaryEncoder
类返回具有byte[]
内容的Message
类型。对于任何二进制内容(如Avro),类型都是
application/octet-stream