@Test
public void testFetchOnPausedPartition() {

    subscriptions.assignFromUser(Arrays.asList(tp));
    subscriptions.seek(tp, 0);
    subscriptions.pause(tp);
    fetcher.sendFetches();
    assertTrue(client.requests().isEmpty());
}