baniuyao/flume-kafka — pull request #3 by jackolantern (2013-11-13 21:58:45+00:00)
Title: 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.