@Test
public void testInvalidMasterServersFixup() {

  FlumeConfiguration cfg = new TestableConfiguration();
  cfg.set(FlumeConfiguration.MASTER_SERVERS, "foo:12345,bar:1345");
  String zksvrs = cfg.getMasterZKServers();
  assertNotSame("foo:12345:2181:3181,bar:1345:2181:3181", zksvrs);
  assertEquals("foo:3181:3182:3183,bar:3181:3182:3183", zksvrs);
}