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)
私はM7も同様の問題で試しました。しかし、明確化のおかげで、意味があります。私はそれで何ができるのかを見つけようとします。 –
私は[問題番号1163](https://github.com/spring-cloud/spring-cloud-stream/issues/1163)を開いた。 –