@Test
public void testSourceCounter() throws IOException {

  runKeepFieldsTest("all");
  assertEquals(10, source.getSourceCounter().getEventAcceptedCount());
  assertEquals(10, source.getSourceCounter().getEventReceivedCount());
}