resp = rest.getDmaapMessage(TOPIC, CONSUMER, CONSUMER_ID, LIMIT, 0);
assertEquals(Response.Status.OK.getStatusCode(), resp.getStatus());
assertEquals("[my-message, my-message-B]", resp.getEntity().toString());
resp = rest.getDmaapMessage(TOPIC, CONSUMER, CONSUMER_ID, LIMIT, 0);
assertEquals(Response.Status.OK.getStatusCode(), resp.getStatus());
assertEquals("[my-message, my-message-B]", resp.getEntity().toString());