@Test public void testGetConfigForTopic() throws Exception { Properties properties = new Properties(); String commonPath = "/data/tracking"; properties.setProperty(GOBBLIN_CONFIG_COMMONPATH, commonPath); properties.setProperty(CONFIG_MANAGEMENT_STORE_URI, configStoreUri); properties.setProperty(CONFIG_MANAGEMENT_STORE_ENABLED, "true"); properties.setProperty("topic.name", "Topic1"); Config topic1Config = ConfigStoreUtils.getConfigForTopic(properties, "topic.name", configClient).get(); Assert.assertEquals(topic1Config.getString("aaaaa"), "bbbb"); }
public static Optional<Config> getConfigForTopic(Properties properties, String topicKey, ConfigClient configClient) { Preconditions.checkArgument(properties.containsKey(topicKey), "Missing required property " + topicKey); String topicName = properties.getProperty(topicKey); return getConfigForTopicWithName(properties, topicName, configClient); }
ConfigStoreUtils { public static Optional<Config> getConfigForTopic(Properties properties, String topicKey, ConfigClient configClient) { Preconditions.checkArgument(properties.containsKey(topicKey), "Missing required property " + topicKey); String topicName = properties.getProperty(topicKey); return getConfigForTopicWithName(properties, topicName, configClient); } }
ConfigStoreUtils { public static Optional<Config> getConfigForTopic(Properties properties, String topicKey, ConfigClient configClient) { Preconditions.checkArgument(properties.containsKey(topicKey), "Missing required property " + topicKey); String topicName = properties.getProperty(topicKey); return getConfigForTopicWithName(properties, topicName, configClient); }  }
ConfigStoreUtils { public static Optional<Config> getConfigForTopic(Properties properties, String topicKey, ConfigClient configClient) { Preconditions.checkArgument(properties.containsKey(topicKey), "Missing required property " + topicKey); String topicName = properties.getProperty(topicKey); return getConfigForTopicWithName(properties, topicName, configClient); }  static Collection<URI> getTopicsURIFromConfigStore(ConfigClient configClient, Path tagUri, String filterString,
      Optional<Config> runtimeConfig); static Optional<String> getConfigStoreUri(Properties properties); static String getTopicNameFromURI(URI uri); static URI getUriStringForTopic(String topicName, String commonPath, String configStoreUri); static Optional<Config> getConfigForTopic(Properties properties, String topicKey, ConfigClient configClient); static Optional<Config> getConfigForTopicWithName(Properties properties, String topicName, ConfigClient configClient); static Config getConfig(ConfigClient client, URI u, Optional<Config> runtimeConfig); static List<KafkaTopic> getTopicsFromConfigStore(Properties properties, String configStoreUri,
      GobblinKafkaConsumerClient kafkaConsumerClient); static List<String> getListOfTopicNamesByFilteringTag(Properties properties, ConfigClient configClient,
      Optional<Config> runtimeConfig, String configStoreUri, String tagConfName); @Deprecated static void setTopicsFromConfigStore(Properties properties, Set<String> blacklist, Set<String> whitelist,
      final String _blacklistTopicKey, final String _whitelistTopicKey); }
ConfigStoreUtils { public static Optional<Config> getConfigForTopic(Properties properties, String topicKey, ConfigClient configClient) { Preconditions.checkArgument(properties.containsKey(topicKey), "Missing required property " + topicKey); String topicName = properties.getProperty(topicKey); return getConfigForTopicWithName(properties, topicName, configClient); }  static Collection<URI> getTopicsURIFromConfigStore(ConfigClient configClient, Path tagUri, String filterString,
      Optional<Config> runtimeConfig); static Optional<String> getConfigStoreUri(Properties properties); static String getTopicNameFromURI(URI uri); static URI getUriStringForTopic(String topicName, String commonPath, String configStoreUri); static Optional<Config> getConfigForTopic(Properties properties, String topicKey, ConfigClient configClient); static Optional<Config> getConfigForTopicWithName(Properties properties, String topicName, ConfigClient configClient); static Config getConfig(ConfigClient client, URI u, Optional<Config> runtimeConfig); static List<KafkaTopic> getTopicsFromConfigStore(Properties properties, String configStoreUri,
      GobblinKafkaConsumerClient kafkaConsumerClient); static List<String> getListOfTopicNamesByFilteringTag(Properties properties, ConfigClient configClient,
      Optional<Config> runtimeConfig, String configStoreUri, String tagConfName); @Deprecated static void setTopicsFromConfigStore(Properties properties, Set<String> blacklist, Set<String> whitelist,
      final String _blacklistTopicKey, final String _whitelistTopicKey); static final String GOBBLIN_CONFIG_TAGS_WHITELIST; static final String GOBBLIN_CONFIG_TAGS_BLACKLIST; static final String GOBBLIN_CONFIG_FILTER; static final String GOBBLIN_CONFIG_COMMONPATH; }