Merge branch 'NewConsumer2' of https://github.com/sborya/samza into NewKafkaSystemConsumer