public boolean getNext(KafkaETLKey key, BytesWritable value) throws IOException {
        if ( !hasMore() ) return false;
        
        boolean gotNext = get(key, value);
        
        if(response != null) {

            while ( !gotNext && respIterator.hasNext()) {
                ByteBufferMessageSet msgSet = respIterator.next();
                if ( hasError(msgSet)) return false;
                messageIt = msgSet.iterator();
                gotNext = get(key, value);
            }
        }
        return gotNext;
    }