Misc fixs

The main fix is in 3931ca6 `KafkaSource.java`  The problem is that the ConsumerIterator.hasNext() method will block forever if there is no timeout set (`consumer.timeout.ms`), or until a new message is written to kafka.  This means that unless the batchsize is actually reached, no messages will be written to the channel.
If `consumer.timeout.ms` is supplied, the way exceptions were being handled, the messages would *still* not be written to the channel.

The rest of the fixes involved things like code formatting, dead code regions, etc.  The only other large change was making `extra-dependencies` a local-repo and adding it to the pom file.  This will make it easier for people to build this project.