GitHub user lhaiesp opened a pull request: https://github.com/apache/samza/pull/587
add retry logic in eventhubs system consumer for non transient error Implement a retry logic in EH system consumer because of lack of nurse job on azure and lack of retry logic in samza standlone. The retry logic can be tuned through config to control max retry count allowed within a certain time window (sliding window). You can merge this pull request into a Git repository by running: $ git pull https://github.com/lhaiesp/samza master Alternatively you can review and apply these changes as the patch at: https://github.com/apache/samza/pull/587.patch To close this pull request, make a commit to your master/trunk branch with (at least) the following in the commit message: This closes #587 ---- commit e2d1227c8922c9403a89a410caf49440df21e4a4 Author: Hai Lu <halu@...> Date: 2018-07-27T20:05:17Z add retry logic in eventhubs system consumer for non transient error ---- ---