We need to send messages to a remote service. I need to implement a circuit breaker to address the scenario in which the remote system is unavailable. I need to change the current offset to reprocess the current offset while the remote system is down. These concerns are similar to those outlined here: https://issues.apache.org/jira/browse/SAMZA-794?<https://issues.apache.org/jira/browse/SAMZA-794>
It looks like Samza's Checkpointing mechanism replaces kafka's auto-commit feature and there is no API for manually manipulating the Checkpointing? Can someone point me in the right direction? Thanks in advance. Jeremiah Adams Software Engineer www.helixeducation.com<http://www.helixeducation.com/> Blog<http://www.helixeducation.com/blog/> | Twitter<https://twitter.com/HelixEducation> | Facebook<https://www.facebook.com/HelixEducation> | LinkedIn<http://www.linkedin.com/company/3609946>
