@Test(groups = INTEGRATION)
public void testNeverReturnsAPreviousReturnedEventTwice() throws SQLException {

   for (int i = 0; i < 100; i++) {
        final MysqlEvent event = new MysqlEvent(i + 1, TEST_TABLE_NAME, INSERT_TYPE, "{}", "{}", new Date());
        insertEvent(event, connection);
        List<MysqlEvent> events = repo.getNewEventsForListener(listener, connection);
        assertEquals(events.size(), 1);
        assertEquals(events.get(0).getEventId(), event.getEventId());
    }
}