Sync with samza upstream, include support for Kafka 0.8.1