提交 0f03d2a4 编写于 作者: B Boyang Jerry Peng 提交者: Jia Zhai

Fix: Messages don't get acked if there is not sink topic (#4815)

### Motivation

A message doesn't get automatically ACKed if there is the output topic is not set
(cherry picked from commit 19b883b7)
上级 7a10bcdf
......@@ -43,7 +43,7 @@ public class PulsarSinkDisable<T> implements Sink<T> {
@Override
public void write(Record<T> record) throws Exception {
// No-op
record.ack();
}
}
Markdown is supported
0% .
You are about to add 0 people to the discussion. Proceed with caution.
先完成此消息的编辑!
想要评论请 注册