From 2d0123bcbfdec669af3e2c6e42b7ec996aafa593 Mon Sep 17 00:00:00 2001 From: YANGLiiN Date: Fri, 12 Apr 2024 14:04:20 +0800 Subject: [PATCH] fix(s3): ControllerKVClient putKV should return result (#1113) --- core/src/main/scala/kafka/log/stream/s3/ControllerKVClient.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/core/src/main/scala/kafka/log/stream/s3/ControllerKVClient.java b/core/src/main/scala/kafka/log/stream/s3/ControllerKVClient.java index d1db6f68b2..0d03690a79 100644 --- a/core/src/main/scala/kafka/log/stream/s3/ControllerKVClient.java +++ b/core/src/main/scala/kafka/log/stream/s3/ControllerKVClient.java @@ -133,7 +133,7 @@ public Builder toRequestBuilder() { } }); this.requestSender.send(task); - return null; + return future; } @Override