added test for client id support on DynamicPartitionConnections.
refactor KafkaUtils.getLastOffset (see: https://cwiki.apache.org/confluence/display/KAFKA/0.8.0+SimpleConsumer+Example)
add "clientId" to FetchRequestBuilder on PartitionManager#fill