[Kinesis] Fix kinesis sink connector does not ack messages. (apache#1…

…0769) ### Motivation Currently, when the kinesis sink connector sends the message successfully, it will not ack the message. ### Modifications * Ack messages after the sink connector send messages successfully.
bharanic-dev · Oct 16, 2021 · 1b8f453 · 1b8f453
1 parent dc4533a
commit 1b8f453
Showing 1 changed file with 1 addition and 0 deletions.
diff --git a/pulsar-io/kinesis/src/main/java/org/apache/pulsar/io/kinesis/KinesisSink.java b/pulsar-io/kinesis/src/main/java/org/apache/pulsar/io/kinesis/KinesisSink.java
@@ -237,6 +237,7 @@ public void onSuccess(UserRecordResult result) {
                 kinesisSink.sinkContext.recordMetric(METRICS_TOTAL_SUCCESS, 1);
             }
             kinesisSink.previousPublishFailed = FALSE;
+            this.resultContext.ack();
             recycle();
         }