use dropWhile rather than filter to trim beginning of fetch response
method to get leader offsets, switch rdd bound to being exclusive start, inclusive end to match offsets typically returned from cluster
method to get consumer offsets, explicit error handling