本文整理了Java中com.pinterest.secor.common.ZookeeperConnector.<init>()方法的一些代码示例，展示了ZookeeperConnector.<init>()的具体用法。这些代码示例主要来源于Github/Stackoverflow/Maven等平台，是从一些精选项目中提取出来的代码，具有较强的参考意义，能在一定程度帮忙到你。ZookeeperConnector.<init>()方法的具体详情如下：
包路径：com.pinterest.secor.common.ZookeeperConnector
类名称：ZookeeperConnector
方法名：<init>

ZookeeperConnector.<init>介绍

暂无

代码示例

代码示例来源：origin: pinterest/secor

/**
 * Init the Uploader with its dependent objects.
 *
 * @param config Secor configuration
 * @param offsetTracker Tracker of the current offset of topics partitions
 * @param fileRegistry Registry of log files on a per-topic and per-partition basis
 * @param uploadManager Manager of the physical upload of log files to the remote repository
 * @param metricCollector component that ingest metrics into monitoring system
 */
public void init(SecorConfig config, OffsetTracker offsetTracker, FileRegistry fileRegistry,
         UploadManager uploadManager, MessageReader messageReader, MetricCollector metricCollector) {
  init(config, offsetTracker, fileRegistry, uploadManager, messageReader,
      new ZookeeperConnector(config), metricCollector);
}

代码示例来源：origin: pinterest/secor

@Override
  public void init(SecorConfig config) {
    mConfig = config;
    mZookeeperConnector = new ZookeeperConnector(mConfig);
    mKafkaMessageTimestampFactory = new KafkaMessageTimestampFactory(mConfig.getKafkaMessageTimestampClass());
  }
}

代码示例来源：origin: pinterest/secor

public static void main(String[] args) {
    try {
      CommandLine commandLine = parseArgs(args);
      String command = commandLine.getOptionValue("command");
      if (!command.equals("delete_committed_offsets")) {
        throw new IllegalArgumentException(
          "command has to be one of \"delete_committed_offsets\"");
      }
      SecorConfig config = SecorConfig.load();
      ZookeeperConnector zookeeperConnector = new ZookeeperConnector(config);
      String topic = commandLine.getOptionValue("topic");
      if (commandLine.hasOption("partition")) {
        int partition =
          ((Number) commandLine.getParsedOptionValue("partition")).intValue();
        TopicPartition topicPartition = new TopicPartition(topic, partition);
        zookeeperConnector.deleteCommittedOffsetPartitionCount(topicPartition);
      } else {
        zookeeperConnector.deleteCommittedOffsetTopicCount(topic);
      }
    } catch (Throwable t) {
      LOG.error("Zookeeper client failed", t);
      System.exit(1);
    }
  }
}

代码示例来源：origin: pinterest/secor

public PartitionFinalizer(SecorConfig config) throws Exception {
  mConfig = config;
  Class kafkaClientClass = Class.forName(mConfig.getKafkaClientClass());
  this.mKafkaClient = (KafkaClient) kafkaClientClass.newInstance();
  this.mKafkaClient.init(config);
  mZookeeperConnector = new ZookeeperConnector(mConfig);
  mMessageParser = (TimestampedMessageParser) ReflectionUtil.createMessageParser(
   mConfig.getMessageParserClass(), mConfig);
  mQuboleClient = new QuboleClient(mConfig);
  if (mConfig.getFileExtension() != null && !mConfig.getFileExtension().isEmpty()) {
    mFileExtension = mConfig.getFileExtension();
  } else if (mConfig.getCompressionCodec() != null && !mConfig.getCompressionCodec().isEmpty()) {
    CompressionCodec codec = CompressionUtil.createCompressionCodec(mConfig.getCompressionCodec());
    mFileExtension = codec.getDefaultExtension();
  } else {
    mFileExtension = "";
  }
  mLookbackPeriods = config.getFinalizerLookbackPeriods();
  LOG.info("Lookback periods: " + mLookbackPeriods);
}

代码示例来源：origin: pinterest/secor

public ProgressMonitor(SecorConfig config)
    throws Exception
{
  mConfig = config;
  mZookeeperConnector = new ZookeeperConnector(mConfig);
  try {
    Class timestampClass = Class.forName(mConfig.getKafkaClientClass());
    this.mKafkaClient = (KafkaClient) timestampClass.newInstance();
    this.mKafkaClient.init(config);
  } catch (ClassNotFoundException | InstantiationException | IllegalAccessException e) {
    throw new RuntimeException(e);
  }
  mMessageParser = (MessageParser) ReflectionUtil.createMessageParser(
      mConfig.getMessageParserClass(), mConfig);
  mPrefix = mConfig.getMonitoringPrefix();
  if (Strings.isNullOrEmpty(mPrefix)) {
    mPrefix = "secor";
  }
  if (mConfig.getStatsDHostPort() != null && !mConfig.getStatsDHostPort().isEmpty()) {
    HostAndPort hostPort = HostAndPort.fromString(mConfig.getStatsDHostPort());
    mStatsDClient = new NonBlockingStatsDClient(null, hostPort.getHostText(), hostPort.getPort(),
        mConfig.getStatsDDogstatsdConstantTags());
  }
}

代码示例来源：origin: pinterest/secor

protected void verify(String zookeeperPath, String expectedOffsetPath) {
    ZookeeperConnector zookeeperConnector = new ZookeeperConnector();
    PropertiesConfiguration properties = new PropertiesConfiguration();
    properties.setProperty("kafka.zookeeper.path", zookeeperPath);
    properties.setProperty("secor.kafka.group", "secor_cg");
    SecorConfig secorConfig = new SecorConfig(properties);
    zookeeperConnector.setConfig(secorConfig);
    Assert.assertEquals(expectedOffsetPath, zookeeperConnector.getCommittedOffsetGroupPath());
  }
}