fix PriorityScheduler bug
fix OffsetManager update and checkpoint bug
Merge pull request #90 from manuzhang/at_least_once

fix OffsetManager update and checkpoint bug
add specs2 and offsetmanager test
Merge branch 'at_least_once' into add_test
change specs2 version
Merge pull request #91 from manuzhang/at_least_once

fix creating checkpoint topic conflicts
each TopicAndPartition checkpoints to its own Kafka topic
Merge remote-tracking branch 'upstream/master'
add offsetManagerSpec
Merge remote-tracking branch 'remotes/origin/at_least_once' into add_test
split consumer thread from main loop
don't load starting offsets when launching an application for the first time
handle the condition when all TopicAndPartitions have no more messages to fetch
make consumer queue size configurable
remove obsolete file
Merge pull request #92 from manuzhang/at_least_once

make consumer run in a separate thread from main loop
add checkpoint id as a work around for nonpersistent application id
Merge remote-tracking branch 'upstream/master'
close thread and change no message log to debug level