Java ConfigType类代码示例-CRMEB社区

Java ConfigType类代码示例

管理

编辑

删除

本文整理汇总了Java中kafka.server.ConfigType类的典型用法代码示例。

如果您正苦于以下问题：

Java ConfigType类的具体用法？Java ConfigType怎么用？

Java ConfigType使用的例子？

那么恭喜您, 这里精选的类代码示例或许可以为您提供帮助。
ConfigType类属于kafka.server包，在下文中一共展示了ConfigType类的4个代码示例，这些例子默认根据受欢迎程度排序。

示例1: getTopicProperties

import kafka.server.ConfigType; //导入依赖的package包/类
/**
 * Get topic configuration
 *
 * @param connection connection
 * @param topicName  topic name
 * @return topic properties
 */
public Properties getTopicProperties(final ZkUtils connection, final String topicName) {
    try {
        return AdminUtils.fetchEntityConfig(connection, ConfigType.Topic(), topicName);
    } catch (IllegalArgumentException | KafkaException e) {
        throw new TopicOperationException(topicName, e.getMessage(), e, this.getClass());
    }
}
 
 开发者ID:mcafee，项目名称:management-sdk-for-kafka，代码行数:15，代码来源:ClusterTools.java

示例2: changeTopicConfig

import kafka.server.ConfigType; //导入依赖的package包/类
/**
 * 修改主题配置
 *
 * @param topic 主题
 * @param prop  属性
 */
private static void changeTopicConfig(String topic, Properties prop) {
    Properties currProp = AdminUtils.fetchEntityConfig(zkUtils, ConfigType.Topic(), topic);
    for (Object key : currProp.keySet()) {
        System.out.println(key + ":" + currProp.get(key));
    }
    currProp.putAll(prop);
    AdminUtils.changeTopicConfig(zkUtils, KAFKA_TOPIC, currProp);
}
 
 开发者ID:wngn123，项目名称:wngn-jms-kafka，代码行数:15，代码来源:TopicOperator.java

示例3: setRetentionTime

import kafka.server.ConfigType; //导入依赖的package包/类
@Override
public void setRetentionTime(final String topic, final Long retentionMs) throws TopicConfigException {
    try {
        doWithZkUtils(zkUtils -> {
            final Properties topicProps = AdminUtils.fetchEntityConfig(zkUtils, ConfigType.Topic(), topic);
            topicProps.setProperty("retention.ms", Long.toString(retentionMs));
            AdminUtils.changeTopicConfig(zkUtils, topic, topicProps);
        });
    } catch (final Exception e) {
        throw new TopicConfigException("Unable to update retention time for topic " + topic, e);
    }
}
 
 开发者ID:zalando，项目名称:nakadi，代码行数:13，代码来源:KafkaTopicRepository.java

示例4: getTopicRetentionTime

import kafka.server.ConfigType; //导入依赖的package包/类
public static Long getTopicRetentionTime(final String topic, final String zkPath) {
    final ZkUtils zkUtils = ZkUtils.apply(zkPath, 30000, 10000, false);
    final Properties topicConfig = AdminUtils.fetchEntityConfig(zkUtils, ConfigType.Topic(), topic);
    return Long.valueOf(topicConfig.getProperty("retention.ms"));
}
 
 开发者ID:zalando，项目名称:nakadi，代码行数:6，代码来源:KafkaTestHelper.java

注：本文中的kafka.server.ConfigType类示例来自自Github/MSDocs等开源代码及文档管理平台，相关代码片段筛选自各路编程大神贡献的开源项目，源码版权归原作者所有，传播和使用请参考对应项目的License；未经允许，请勿转载。