本文整理了Java中com.pinterest.secor.common.ZookeeperConnector.<init>()
方法的一些代码示例,展示了ZookeeperConnector.<init>()
的具体用法。这些代码示例主要来源于Github
/Stackoverflow
/Maven
等平台,是从一些精选项目中提取出来的代码,具有较强的参考意义,能在一定程度帮忙到你。ZookeeperConnector.<init>()
方法的具体详情如下:
包路径:com.pinterest.secor.common.ZookeeperConnector
类名称: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());
}
}
内容来源于网络,如有侵权,请联系作者删除!