kafka08 simple consumer firehose

I also changed druid-api package, added a method "public long getLastOffsetCommitTime(); " in "interface Firehose". The  way to call new commit method is hacked by using reflection,  quick and dirty way, need to refactor to add some method to interface. 
Can you explain what you are trying to accomplish here?  I don't believe you need to do any of this reflection or expose the methods that you have exposed, but I'd like to understand the motivation to see if there is something I'm not understanding.