本文整理了Java中org.apache.kafka.common.utils.Utils.loadProps()方法的一些代码示例，展示了Utils.loadProps()的具体用法。这些代码示例主要来源于Github/Stackoverflow/Maven等平台，是从一些精选项目中提取出来的代码，具有较强的参考意义，能在一定程度帮忙到你。Utils.loadProps()方法的具体详情如下：
包路径：org.apache.kafka.common.utils.Utils
类名称：Utils
方法名：loadProps

Utils.loadProps介绍

[英]Read a properties file from the given path
[中]从给定路径读取属性文件

代码示例

代码示例来源：origin: linkedin/kafka-monitor

props.put(ProduceServiceConfig.PRODUCE_RECORD_SIZE_BYTE_CONFIG, res.getString("recordSize"));
if (res.getString("producerConfig") != null)
 props.put(ProduceServiceConfig.PRODUCER_PROPS_CONFIG, Utils.loadProps(res.getString("producerConfig")));
 props.put(ConsumeServiceConfig.CONSUMER_PROPS_CONFIG, Utils.loadProps(res.getString("consumerConfig")));
if (res.getString("consumerClassName") != null)
 props.put(ConsumeServiceConfig.CONSUMER_CLASS_CONFIG, res.getString("consumerClassName"));

代码示例来源：origin: org.apache.kafka/kafka_2.11

final Properties properties = new Properties();
if (options.has(commandConfigOption)) {
  properties.putAll(Utils.loadProps(options.valueOf(commandConfigOption)));

代码示例来源：origin: org.apache.kafka/kafka

final Properties properties = new Properties();
if (options.has(commandConfigOption)) {
  properties.putAll(Utils.loadProps(options.valueOf(commandConfigOption)));

代码示例来源：origin: org.apache.kafka/kafka_2.12

final Properties properties = new Properties();
if (options.has(commandConfigOption)) {
  properties.putAll(Utils.loadProps(options.valueOf(commandConfigOption)));

代码示例来源：origin: salesforce/mirus

public static void main(String[] argv) throws Exception {
 Mirus.Args args = new Mirus.Args();
 JCommander jCommander =
   JCommander.newBuilder()
     .programName(OffsetStatus.class.getSimpleName())
     .addObject(args)
     .build();
 try {
  jCommander.parse(argv);
 } catch (Exception e) {
  jCommander.usage();
  throw e;
 }
 if (args.help) {
  jCommander.usage();
  System.exit(1);
 }
 Map<String, String> workerProps =
   !args.workerPropertiesFile.isEmpty()
     ? Utils.propsToStringMap(Utils.loadProps(args.workerPropertiesFile))
     : Collections.emptyMap();
 applyOverrides(args.overrides, workerProps);
 startConnect(workerProps);
}

代码示例来源：origin: org.apache.servicemix.bundles/org.apache.servicemix.bundles.kafka_2.11

final Properties properties = new Properties();
if (options.has(commandConfigOption)) {
  properties.putAll(Utils.loadProps(options.valueOf(commandConfigOption)));

代码示例来源：origin: org.apache.kafka/connect-runtime

Utils.propsToStringMap(Utils.loadProps(workerPropsFile)) : Collections.<String, String>emptyMap();
connect.start();
for (final String connectorPropsFile : Arrays.copyOfRange(args, 1, args.length)) {
  Map<String, String> connectorProps = Utils.propsToStringMap(Utils.loadProps(connectorPropsFile));
  FutureCallback<Herder.Created<ConnectorInfo>> cb = new FutureCallback<>(new Callback<Herder.Created<ConnectorInfo>>() {
    @Override

代码示例来源：origin: salesforce/mirus

private static MirusOffsetTool newOffsetTool(Args args) throws IOException {
 // This needs to be the admin topic properties.
 // By default these are in the worker properties file, as this has the has admin producer and
 // consumer settings.  Separating these might be wise - also useful for storing state in
 // source cluster if it proves necessary.
 final Map<String, String> properties =
   !args.propertiesFile.isEmpty()
     ? Utils.propsToStringMap(Utils.loadProps(args.propertiesFile))
     : Collections.emptyMap();
 final DistributedConfig config = new DistributedConfig(properties);
 final KafkaOffsetBackingStore offsetBackingStore = new KafkaOffsetBackingStore();
 offsetBackingStore.configure(config);
 // Avoid initializing the entire Kafka Connect plugin system by assuming the
 // internal.[key|value].converter is org.apache.kafka.connect.json.JsonConverter
 final Converter internalConverter = new JsonConverter();
 internalConverter.configure(config.originalsWithPrefix("internal.key.converter."), true);
 final OffsetSetter offsetSetter = new OffsetSetter(internalConverter, offsetBackingStore);
 final OffsetFetcher offsetFetcher = new OffsetFetcher(config, internalConverter);
 final OffsetSerDe offsetSerDe = OffsetSerDeFactory.create(args.format);
 return new MirusOffsetTool(args, offsetFetcher, offsetSetter, offsetSerDe);
}

代码示例来源：origin: org.apache.kafka/connect-runtime

Utils.propsToStringMap(Utils.loadProps(workerPropsFile)) : Collections.<String, String>emptyMap();

代码示例来源：origin: ucarGroup/DataLink

String workerPropsFile = args[0];//if assigned,use the assigned file
  workerProps = !workerPropsFile.isEmpty() ?
      Utils.propsToStringMap(Utils.loadProps(workerPropsFile)) : Collections.<String, String>emptyMap();
} else {
  workerProps = Utils.propsToStringMap(buildWorkerProps());