You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@pulsar.apache.org by mm...@apache.org on 2019/05/19 00:49:26 UTC
[pulsar] 11/26: ack records in datagenerator print sink (#4052)
This is an automated email from the ASF dual-hosted git repository.
mmerli pushed a commit to branch branch-2.3
in repository https://gitbox.apache.org/repos/asf/pulsar.git
commit a0976d655a964c247dbeb2d4ed24e9a77c40bd3b
Author: Boyang Jerry Peng <je...@gmail.com>
AuthorDate: Tue Apr 16 17:32:56 2019 -0700
ack records in datagenerator print sink (#4052)
---
.../java/org/apache/pulsar/io/datagenerator/DataGeneratorPrintSink.java | 1 +
1 file changed, 1 insertion(+)
diff --git a/pulsar-io/data-generator/src/main/java/org/apache/pulsar/io/datagenerator/DataGeneratorPrintSink.java b/pulsar-io/data-generator/src/main/java/org/apache/pulsar/io/datagenerator/DataGeneratorPrintSink.java
index 6944247..2573958 100644
--- a/pulsar-io/data-generator/src/main/java/org/apache/pulsar/io/datagenerator/DataGeneratorPrintSink.java
+++ b/pulsar-io/data-generator/src/main/java/org/apache/pulsar/io/datagenerator/DataGeneratorPrintSink.java
@@ -36,6 +36,7 @@ public class DataGeneratorPrintSink implements Sink<Person> {
@Override
public void write(Record<Person> record) throws Exception {
log.info("RECV: {}", record.getValue());
+ record.ack();
}
@Override