@Test(expected = FlumeException.class)
public void testZKQuorumIncorrectPorts() throws Exception {

  Context ctx = getContextForSimpleHBase2EventSerializer();
  Context tmpContext = new Context(ctx.getParameters());
  String zkQuorum = "zk1.flume.apache.org:3345, zk2.flume.apache.org:3342, " +
                    "zk3.flume.apache.org:3342";
  tmpContext.put("batchSize", "2");
  tmpContext.put(HBase2SinkConfigurationConstants.ZK_QUORUM, zkQuorum);
  tmpContext.put(HBase2SinkConfigurationConstants.ZK_ZNODE_PARENT,
                 conf.get(HConstants.ZOOKEEPER_ZNODE_PARENT,
                          HConstants.DEFAULT_ZOOKEEPER_ZNODE_PARENT));
  HBase2Sink sink = new HBase2Sink();
  Configurables.configure(sink, tmpContext);
  Assert.fail();
}