@Test
public void testRefreshOffsetWithNoFetchableOffsets() {

    client.prepareResponse(consumerMetadataResponse(node, Errors.NONE.code()));
    coordinator.ensureCoordinatorReady();
    subscriptions.assignFromUser(Arrays.asList(tp));
    subscriptions.needRefreshCommits();
    client.prepareResponse(offsetFetchResponse(tp, Errors.NONE.code(), "", -1L));
    coordinator.refreshCommittedOffsetsIfNeeded();
    assertFalse(subscriptions.refreshCommitsNeeded());
    assertEquals(null, subscriptions.committed(tp));
}