kafka trunk support

kafka trunk support CommitOffset change