代码示例类Java ConfigType

喜欢ヅ旅行 2023-10-04 23:12 43阅读 0赞

本文整理汇总了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,finalString topicName){try{return AdminUtils.fetchEntityConfig(connection, ConfigType.Topic(), topicName);}catch(IllegalArgumentException|KafkaException e){thrownewTopicOperationException(topicName, e.getMessage(), e, this.getClass());}}
     
     开发者ID:mcafee，项目名称:management-sdk-for-kafka，代码行数:15，代码来源:ClusterTools.java

Copy

### 示例2: changeTopicConfig ###

import kafka.server.ConfigType;//导入依赖的package包/类/**
     * 修改主题配置
     *
     * @param topic 主题
     * @param prop  属性
     */privatestaticvoidchangeTopicConfig(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

Copy

### 示例3: setRetentionTime ###

import kafka.server.ConfigType;//导入依赖的package包/类
    @Override
    publicvoidsetRetentionTime(finalString 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){thrownewTopicConfigException("Unable to update retention time for topic "+ topic, e);}}
     
     开发者ID:zalando，项目名称:nakadi，代码行数:13，代码来源:KafkaTopicRepository.java

Copy

### 示例4: getTopicRetentionTime ###

import kafka.server.ConfigType;//导入依赖的package包/类publicstatic Long getTopicRetentionTime(finalString topic,finalString 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

Copy