2017-12-24 31 views
1

HTTP上で継続的な状態変更を提供するために、Kafka SteamsとSpring WebfluxをNetty上で使用してストリーミングエンジンを構築したいと考えています。私は私のGradleファイル春のブートアプリでSpringクラウドストリームバインダーkafkaがNettyで実行されない

compile('org.springframework.cloud:spring-cloud-stream-binder-kafka') 

依存関係を持っている場合、私は気づいたことは組み込みのTomcatの代わりに、網状で始まります。

私はそれが網状で始まるよりも

compile('org.springframework.cloud:spring-cloud-stream-binder-kafka') 

を削除した場合。

spring-cloud-stream-binder-kafkaの反応機能を提供しないように設計されているのですか、何か間違っていますか?フルグラデルの設定は次のようになります。

buildscript { 
    ext { 
     springBootVersion = '2.0.0.M4' 
     springKafkaVersion = '2.1.0.RELEASE' 
     kafkaStreamsVersion = '1.0.0' 
     confluentVersion = '4.0.0' 
     avroVersion = '1.8.2' 
     avroPluginVersion = '0.12.0' 
    } 
    repositories { 
     mavenCentral() 
     maven { url "https://repo.spring.io/snapshot" } 
     maven { url "https://repo.spring.io/milestone" } 
     maven { url "https://plugins.gradle.org/m2/" } 
    } 
    dependencies { 
     classpath("org.springframework.boot:spring-boot-gradle-plugin:$springBootVersion") 
     classpath "com.commercehub.gradle.plugin:gradle-avro-plugin:$avroPluginVersion" 
    } 
} 

apply plugin: 'java' 
apply plugin: 'org.springframework.boot' 
apply plugin: 'io.spring.dependency-management' 
apply plugin: "com.commercehub.gradle.plugin.avro" 

group = 'eu.lkokhreidze' 
version = '0.0.1-SNAPSHOT' 
sourceCompatibility = 1.8 

repositories { 
    mavenCentral() 
    maven { url "https://repo.spring.io/snapshot" } 
    maven { url "https://repo.spring.io/milestone" } 
    maven { url "https://packages.confluent.io/maven/" } 
} 

ext { 
    springCloudVersion = 'Finchley.M3' 
} 

dependencies { 
    compile('org.springframework.boot:spring-boot-starter-webflux') 
    compile('org.springframework.boot:spring-boot-starter-actuator') 
    compile('org.springframework.cloud:spring-cloud-stream-binder-kafka') 
    compile("org.springframework.kafka:spring-kafka:$springKafkaVersion") 

    compile("org.apache.avro:avro:$avroVersion") 
    compile("org.apache.kafka:kafka-streams:$kafkaStreamsVersion") 
    compile("io.confluent:kafka-streams-avro-serde:$confluentVersion") 

    compileOnly('org.springframework.boot:spring-boot-configuration-processor') 
    compileOnly('org.projectlombok:lombok') 

    testCompile('org.springframework.boot:spring-boot-starter-test') 
    testCompile('io.projectreactor:reactor-test') 
} 

dependencyManagement { 
    imports { 
     mavenBom "org.springframework.cloud:spring-cloud-dependencies:$springCloudVersion" 
    } 
} 

compileJava.dependsOn(generateAvroJava) 
compileTestJava.dependsOn(generateTestAvroJava) 

答えて

2

これは意図的なものではありません。バインダーの2.0バージョンはまだ開発中です。スプリングクラウドストリームのアクチュエータエンドポイントはまだ移行されていない可能性があります。

私はあなたがブートM4を使用しているのを見ています - 現在の2.0マイルストーンはM7です。

問題が解決するかどうかわかりません。あなたはmvcのジャーを除外することができるかもしれませんが、アクチュエータが動作するかどうかわからない、またはストリームのアクチュエータを無効にできる場合はYMMVです。

あなたはspring-kafkaを直接使用することができます。

+0

私はM7も同様の問題で試しました。しかし、明確化のおかげで、意味があります。私はそれで何ができるのかを見つけようとします。 –

+0

私は[問題番号1163](https://github.com/spring-cloud/spring-cloud-stream/issues/1163)を開いた。 –

関連する問題