Java ConfigType類代碼示例

管理

編輯

刪除

CRMEB-慕白寒窗雪 2023-02-23 17:54:17

其他

本文整理匯總了Java中kafka.server.ConfigType類的典型用法代碼示例。

如果您正苦于以下問(wèn)題：

Java ConfigType類的具體用法？Java ConfigType怎么用？

Java ConfigType使用的例子？

那么恭喜您, 這里精選的類代碼示例或許可以為您提供幫助。
ConfigType類屬于kafka.server包，在下文中一共展示了ConfigType類的4個(gè)代碼示例，這些例子默認(rèn)根據(jù)受歡迎程度排序。

示例1: getTopicProperties

import kafka.server.ConfigType; //導(dǎo)入依賴的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());
    }
}
 
 開(kāi)發(fā)者ID:mcafee，項(xiàng)目名稱:management-sdk-for-kafka，代碼行數(shù):15，代碼來(lái)源:ClusterTools.java

示例2: changeTopicConfig

import kafka.server.ConfigType; //導(dǎo)入依賴的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);
}
 
 開(kāi)發(fā)者ID:wngn123，項(xiàng)目名稱:wngn-jms-kafka，代碼行數(shù):15，代碼來(lái)源:TopicOperator.java

示例3: setRetentionTime

import kafka.server.ConfigType; //導(dǎo)入依賴的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);
    }
}
 
 開(kāi)發(fā)者ID:zalando，項(xiàng)目名稱:nakadi，代碼行數(shù):13，代碼來(lái)源:KafkaTopicRepository.java

示例4: getTopicRetentionTime

import kafka.server.ConfigType; //導(dǎo)入依賴的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"));
}
 
 開(kāi)發(fā)者ID:zalando，項(xiàng)目名稱:nakadi，代碼行數(shù):6，代碼來(lái)源:KafkaTestHelper.java

注：本文中的kafka.server.ConfigType類示例來(lái)自自Github/MSDocs等開(kāi)源代碼及文檔管理平臺(tái)，相關(guān)代碼片段篩選自各路編程大神貢獻(xiàn)的開(kāi)源項(xiàng)目，源碼版權(quán)歸原作者所有，傳播和使用請(qǐng)參考對(duì)應(yīng)項(xiàng)目的License；未經(jīng)允許，請(qǐng)勿轉(zhuǎn)載。

請(qǐng)登錄后查看

java開(kāi)發(fā)

CRMEB-慕白寒窗雪最后編輯于2023-02-23 17:54:45

快捷回復(fù)