2016-11-25 160 views
0

尝试使用以下example from Spring Docs春季云流缺少架构模块

@Bean 
public MessageConverter userMessageConverter() throws IOException { 
    AvroSchemaMessageConverter avroSchemaMessageConverter { 
    return new AvroSchemaMessageConverter(MimeType.valueOf("avro/bytes"); 
} 

使用摇篮如下

buildscript { 
    ext { 
    springBootVersion = '1.4.2.RELEASE' 
    } 
    dependencies { 
    classpath("org.springframework.boot:spring-boot-gradle-plugin:${springBootVersion}") 
    } 
} 

apply plugin: 'org.springframework.boot' 

dependencies { 
    compile('org.springframework.cloud:spring-cloud-stream') 
    compile('org.springframework.cloud:spring-cloud-starter-stream-kafka') 
} 

dependencyManagement { 
    imports { 
    mavenBom "org.springframework.cloud:spring-cloud-dependencies:Camden.SR2" 
    } 
} 

摇篮加载弹簧云流的正确版本1.1.0.RELEASE但它不符合Github Repo。该工件缺少org.springframework.cloud.stream.schema程序包/源代码。

我在这里错过了什么吗?

回答

0

神器org.springframework.cloud:spring-cloud-starter-stream-kafka带来了spring-cloud-stream,spring-cloud-stream-codec和相关的依赖,如spring-integration。你将不得不明确定义org.springframework.cloud:spring-cloud-stream-schema

此外,您不需要指定'org.springframework.cloud:spring-cloud-stream',因为它将通过org.springframework.cloud:spring-cloud-stream-binder-kafka作为org.springframework.cloud:spring-cloud-starter-stream-kafka的一部分。