adding checkout for auto ack
@@ -305,11 +305,13 @@ public class JavaInstanceRunnable implements AutoCloseable, Runnable {
if (result.getResult() != null) {
sendOutputMessage(srcRecord, result.getResult());
} else {
+ if (instanceConfig.getFunctionDetails().getAutoAck()) {
// the function doesn't produce any result or the user doesn't want the result.
srcRecord.ack();
}
}
}
+ }
private void sendOutputMessage(Record srcRecord, Object output) {
try {
