Skip to content

Commit 12a5dd5

Browse files
nlu90tuteng
authored andcommitted
remove future.join() from PulsarSinkEffectivelyOnceProcessor (#6361)
(cherry picked from commit 943c903)
1 parent 7ff6b8b commit 12a5dd5

File tree

1 file changed

+0
-1
lines changed
  • pulsar-functions/instance/src/main/java/org/apache/pulsar/functions/sink

1 file changed

+0
-1
lines changed

pulsar-functions/instance/src/main/java/org/apache/pulsar/functions/sink/PulsarSink.java

Lines changed: 0 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -234,7 +234,6 @@ public void sendOutputMessage(TypedMessageBuilder<T> msg, Record<T> record) {
234234
CompletableFuture<MessageId> future = msg.sendAsync();
235235

236236
future.thenAccept(messageId -> record.ack()).exceptionally(getPublishErrorHandler(record, true));
237-
future.join();
238237
}
239238
}
240239

0 commit comments

Comments
 (0)