class ZookeeperCheckpointManager implements ICheckPointManager {

  public ZookeeperCheckpointManager(CustomizedConsumerConfig config, String groupId) {
    this.commitZkClient = ZkUtils.createZkClient(
        config.getProperty(Constants.COMMIT_ZOOKEEPER_SERVER_CONFIG),
        config.getInt(ConsumerConfig.SESSION_TIMEOUT_MS_CONFIG, 10000),
        config.getInt(ConsumerConfig.REQUEST_TIMEOUT_MS_CONFIG, 10000));
    this.groupId = groupId;
    this.commitExecutor = Executors.newFixedThreadPool(10);
    KafkaUReplicatorMetricsReporter.get().registerMetric(COMMIT_FAILURE_METER_NAME, commitFailure);
  }

  public  ZookeeperCheckpointManager(CustomizedConsumerConfig config, String groupId);

}