mjschmidt opened a new issue #2909: Add ack and fail to Streamlet API URL: https://github.com/apache/incubator-heron/issues/2909 The default behavior for heron streamlet is not to ack/fail messages. Upon further inspection we realized this is not only the default, but the only option for Streamlet as it only uses emit, which will not ack and fail messages. This currently isn't configurable. The code can be seen here: https://github.com/apache/incubator-heron/blob/6029c28943b7ad85be6fa175d20e0e908fb199b6/heron/api/src/java/org/apache/heron/streamlet/impl/sources/ComplexSource.java#L60 What steps would be required to add this functionality? This would aid greatly in us transitioning to Streamlet.
---------------------------------------------------------------- This is an automated message from the Apache Git Service. To respond to the message, please log on GitHub and use the URL above to go to the specific comment. For queries about this service, please contact Infrastructure at: [email protected] With regards, Apache Git Services
