Spring Cloud DataflowでAvroメッセージコンバータを有効にする

Question

Spring Cloud Dataflowでストリームアプリケーションを実装しています。私はAvroベースのスキーマレジストリクライアントをシリアライズとスキーマの制御に使用したいと考えています。 私の基本的な目標は、ソースアプリケーションにいくつかの外部データを供給し、それを準備済みのavroベースのスキーマに変換し、このスキーマのみを受け入れるシンクアプリに送信することです。 スキーマのファイルバージョンではなく、外部スキーマレジストリサーバーからスキーマを使用したいと考えています。 私のコードは次のようになります。

@EnableBinding(Source.class) 
@EnableSchemaRegistryClient 
public class DisSampleSource { 

    private final DisSampleSourceProperties properties; 

    @Inject 
    public DisSampleSource(DisSampleSourceProperties properties) { 
     this.properties = properties; 
    } 

    @InboundChannelAdapter(Source.OUTPUT) 
    public String feed() throws IOException { 
     if (!Paths.get(properties.getPath()).toFile().exists()) { 
      throw new InvalidPathException(this.properties.getPath(), 
        "The file does not exists or is of not proper type."); 
     } 
     return new String(Files.readAllBytes(Paths.get(properties.getPath())), StandardCharsets.UTF_8); 
    } 
} 

POM：

<dependency> 
     <groupId>org.springframework.cloud</groupId> 
     <artifactId>spring-cloud-stream-schema</artifactId> 
     <version>1.1.1.RELEASE</version> 
    </dependency> 

アプリケーションの起動時には、私が渡していますプロパティ：

現時点で

--spring.cloud.stream.bindings.output.contentType=application/foo.bar.v1+avro 

、アプリケーションは次の例外を除いて起動に失敗します：

2017-02-13 16:25:30.430 WARN 2444 --- [   main] ationConfigEmbeddedWebApplicationContext : Exception encountered during context initialization - cancelling refresh attempt: org.springframework.beans.factory.BeanCreationException: Error creating bean with name 'disSampleSource' defined in URL [jar:file:/D:/git/dis/sample/source/target/dis-sample-source-1.0.0-SNAPSHOT.jar!/BOOT-INF/classes!/com/atsisa/bit/dis/sample/DisSampleSource.class]: Initialization of bean failed; nested exception is org.springframework.beans.factory.UnsatisfiedDependencyException: Error creating bean with name 'org.springframework.cloud.stream.config.ChannelBindingAutoConfiguration': Unsatisfied dependency expressed through field 'adapters'; nested exception is org.springframework.beans.factory.BeanCreationException: Error creating bean with name 'org.springframework.cloud.stream.messaging.Source': Invocation of init method failed; nested exception is org.springframework.cloud.stream.converter.ConversionException: No message converter is registered for application/foo.bar.v1+avro 
2017-02-13 16:25:30.440 INFO 2444 --- [   main] o.apache.catalina.core.StandardService : Stopping service Tomcat 
2017-02-13 16:25:30.480 INFO 2444 --- [   main] utoConfigurationReportLoggingInitializer : 

Error starting ApplicationContext. To display the auto-configuration report re-run your application with 'debug' enabled. 
2017-02-13 16:25:30.485 ERROR 2444 --- [   main] o.s.boot.SpringApplication    : Application startup failed 

org.springframework.beans.factory.BeanCreationException: Error creating bean with name 'disSampleSource' defined in URL [jar:file:/D:/git/dis/sample/source/target/dis-sample-source-1.0.0-SNAPSHOT.jar!/BOOT-INF/classes!/com/atsisa/bit/dis/sample/DisSampleSource.class]: Initialization of bean failed; nested exception is org.springframework.beans.factory.UnsatisfiedDependencyException: Error creating bean with name 'org.springframework.cloud.stream.config.ChannelBindingAutoConfiguration': Unsatisfied dependency expressed through field 'adapters'; nested exception is org.springframework.beans.factory.BeanCreationException: Error creating bean with name 'org.springframework.cloud.stream.messaging.Source': Invocation of init method failed; nested exception is org.springframework.cloud.stream.converter.ConversionException: No message converter is registered for application/foo.bar.v1+avro 
     at org.springframework.beans.factory.support.AbstractAutowireCapableBeanFactory.doCreateBean(AbstractAutowireCapableBeanFactory.java:562) ~[spring-beans-4.3.4.RELEASE.jar!/:4.3.4.RELEASE] 
     at org.springframework.beans.factory.support.AbstractAutowireCapableBeanFactory.createBean(AbstractAutowireCapableBeanFactory.java:482) ~[spring-beans-4.3.4.RELEASE.jar!/:4.3.4.RELEASE] 
     at org.springframework.beans.factory.support.AbstractBeanFactory$1.getObject(AbstractBeanFactory.java:306) ~[spring-beans-4.3.4.RELEASE.jar!/:4.3.4.RELEASE] 
     at org.springframework.beans.factory.support.DefaultSingletonBeanRegistry.getSingleton(DefaultSingletonBeanRegistry.java:230) ~[spring-beans-4.3.4.RELEASE.jar!/:4.3.4.RELEASE] 
     at org.springframework.beans.factory.support.AbstractBeanFactory.doGetBean(AbstractBeanFactory.java:302) ~[spring-beans-4.3.4.RELEASE.jar!/:4.3.4.RELEASE] 
     at org.springframework.beans.factory.support.AbstractBeanFactory.getBean(AbstractBeanFactory.java:197) ~[spring-beans-4.3.4.RELEASE.jar!/:4.3.4.RELEASE] 
     at org.springframework.beans.factory.support.DefaultListableBeanFactory.preInstantiateSingletons(DefaultListableBeanFactory.java:754) ~[spring-beans-4.3.4.RELEASE.jar!/:4.3.4.RELEASE] 
     at org.springframework.context.support.AbstractApplicationContext.finishBeanFactoryInitialization(AbstractApplicationContext.java:866) ~[spring-context-4.3.4.RELEASE.jar!/:4.3.4.RELEASE] 

どうしたのですか？

Answer 1

Avro目的は、将来的に他のフォーマットをサポートすることであるとして（春クラウドストリームスキーマのオプションの依存関係です。スキーマのサポートを有効にするためには、あなたは、単にプロジェクトに

<dependency> 
    <groupId>org.apache.avro</groupId> 
    <artifactId>avro</artifactId> 
    <version>1.8.1</version> 
</dependency> 

を追加する必要があります。