mesos/spark — pull request #372 by Reinvigorate (2013-01-15 00:30:00+00:00)
Title: Removing offset management code that is non-existent in kafka 0.7.0+

KafkaInputDStream was referencing offset management code that doesn't exist in Kafka 0.7.0+, and which Kafka does under the hood. It would cause the KafkaInputDStream to emit a singe message, and would subsequently die. This fixed the issue for us.