updating code so that it will work with 0.8.0
Fix mvn deps for kafka 0.8.0 to target scala 2.9.2. Fix KafkaClient.fetch to translate and throw exceptions on error in the FetchResponse. Add support for new river configuration named 'startFromNewestOffset'. This flag allow the river to be setup either to start from the newest or oldest partition offset if/when the river encounters an OffsetOutOfRangeException. Fixed a couple tests that were failing due to the new clientName param in the KafkaClient connect method.
Change move dumpStats within try/catch so river doesn't stop on socket timeout exceptions
null check on thread during river close
Version upgrades, fix tests

 * Kafka 0.8.1
 * ElasticSearch 1.0.1
 * Scala 2.10.3
tabs -> spaces