fix #222, fix timestamp filter



<!-- Reviewable:start -->
[<img src="https://reviewable.io/review_button.png" height=40 alt="Review on Reviewable"/>](https://reviewable.io/reviews/intel-hadoop/gearpump/241)
<!-- Reviewable:end -->

You need to define some interface to wrap the kafka. 
And the kafka related code should not be directly connected with TaskActor.

For example:
you can define a TimeReplayableSource.

trait TimeReplayableSource {
  def setStartTime(timestamp : Timestamp) : Unit
  def pull(number : Int) : List[Message]
}