public static void main(String[] args) throws Exception {
Configuration conf = HBaseConfiguration.create();
conf.setBoolean("hbase.replication", true);
ZooKeeperItf zk = ZkUtil.connect("localhost", 20000);
SepModel sepModel = new SepModelImpl(zk, conf);
final String subscriptionName = "logger";
if (!sepModel.hasSubscription(subscriptionName)) {
sepModel.addSubscriptionSilent(subscriptionName);
}
PayloadExtractor payloadExtractor = new BasePayloadExtractor(Bytes.toBytes("sep-user-demo"), Bytes.toBytes("info"),
Bytes.toBytes("payload"));