Added KafkaClient.fetchOffset and uses it when creating WeaveController.