This commit is contained in:
Trask Stalnaker 2022-07-31 00:50:42 -07:00 committed by GitHub
parent cf313eb361
commit 9e460e28ef
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
2 changed files with 3 additions and 3 deletions

View File

@ -24,7 +24,7 @@ dependencies {
exclude("io.micrometer", "micrometer-core")
}
compileOnly("org.springframework.kafka:spring-kafka:2.7.1")
compileOnly("org.springframework.kafka:spring-kafka:2.9.0")
compileOnly("org.springframework.boot:spring-boot-starter-actuator:$springBootVersion")
compileOnly("org.springframework.boot:spring-boot-starter-aop:$springBootVersion")
compileOnly("org.springframework.boot:spring-boot-starter-web:$springBootVersion")
@ -41,7 +41,7 @@ dependencies {
compileOnly("io.opentelemetry:opentelemetry-exporter-zipkin")
compileOnly(project(":instrumentation-annotations"))
testImplementation("org.springframework.kafka:spring-kafka:2.7.1")
testImplementation("org.springframework.kafka:spring-kafka:2.9.0")
testImplementation("org.springframework.boot:spring-boot-starter-actuator:$springBootVersion")
testImplementation("org.springframework.boot:spring-boot-starter-aop:$springBootVersion")
testImplementation("org.springframework.boot:spring-boot-starter-webflux:$springBootVersion")

View File

@ -90,7 +90,7 @@ class KafkaIntegrationTest {
() -> {
kafkaTemplate.executeInTransaction(
ops -> {
ops.send("testTopic", "10", "testSpan");
ops.usingCompletableFuture().send("testTopic", "10", "testSpan");
return 0;
});
});