Fix a few issues related to:

- Fix the error handling on kafka broker offline, so we can proceed as long as the error code is not LeaderNotAvailable

- Fix the bug on sweeper reprocessing to we will process both the input paths and destPath
Merge remote-tracking branch 'upstream/master'
Fix an error in contains vs. containsKey

Not sure why this line changed, change it back to what it were.
Change the line 253 and 281 back to where it were before.

I didn't change those lines either, not sure whether it's coming from git merge
Merge pull request #112 from henrylinkedin/master

Fix the error handling on hourly to ignore certain kafka error codes, fixed the bug on reprocessing on sweeper