KafkaClient#subscribe scaladoc says the following:
-1 specified start from tail (new message arriving to topic)
This is wrong as this will start reading the topic from the beginning rather than tail according to code. The message should say something like following.
TailOffset specified start from tail (new message arriving to topic)