public class Utils extends Object
Constructor and Description |
---|
Utils() |
Modifier and Type | Method and Description |
---|---|
static Properties |
getKafkaConfig(Identity identity,
org.osgi.service.cm.ConfigurationAdmin configAdmin,
String type) |
static Set<String> |
getTopics(Properties kafkaConfig) |
static <T> T |
runWithGivenClassLoader(java.util.function.Supplier<T> supplier,
ClassLoader classLoader) |
static <T> T |
runWithNullContextClassLoader(java.util.function.Supplier<T> supplier) |
public static <T> T runWithNullContextClassLoader(java.util.function.Supplier<T> supplier)
public static <T> T runWithGivenClassLoader(java.util.function.Supplier<T> supplier, ClassLoader classLoader)
public static Set<String> getTopics(Properties kafkaConfig) throws ExecutionException, InterruptedException
public static Properties getKafkaConfig(Identity identity, org.osgi.service.cm.ConfigurationAdmin configAdmin, String type)
Copyright © 2020. All rights reserved.