See https://stackoverflow.com/questions/48420085/kafkaspout-is-not-emmiting-message
GitHub Pull Request #2574