storm-kafka-client：1.2.2使用Yaml的KafkaSpoutConfig

Question

我试图通过YAML配置KafkaSpout，我收到以下错误

线程“main”中的异常java.lang.IllegalArgumentException：参数类型不匹配

下面是我的YAML文件中的一点

name: "SampleTopology"

components:
- id: "onlyValueRecordTranslator"
className: "org.apache.storm.kafka.spout.DefaultRecordTranslator"

- id: "spoutConfigBuilder"
  className: 
 "org.apache.storm.kafka.spout.KafkaSpoutConfig$Builder"
  constructorArgs:
  - "localhost:9092"
  - ["myKafkaTopic"]
  properties:
  - name: "firstPollOffsetStrategy"
    value: "LATEST"
  - name: "recordTranslator"
    ref: "onlyValueRecordTranslator"
 configMethods:
  - name: "setProp"
    args:
      - {
        "key.deserializer" : 
  "org.apache.kafka.common.serialization.StringDeserializer",
        "value.deserializer": 
  "org.apache.kafka.common.serialization.StringDeserializer"
      }


  - id: "spoutConfig"
  className: "org.apache.storm.kafka.spout.KafkaSpoutConfig"
  constructorArgs:
  - ref: "spoutConfigBuilder"

有人可以指点我如何使用KafkaSpoutConfig虽然YAML？

我正在使用以下版本的storm和kafka

org.apache.storm:storm-core:1.2.2
org.apache.storm:storm-kafka-client:1.2.2
org.apache.storm', name: 'flux-core', version: '1.2.2

Answer 1

YAML看起来正确（假设破碎的缩进是一个复制粘贴错误，否则你需要修复它）。

您受到https://github.com/apache/storm/pull/2575中修复的错误的影响。它只在Storm 2.0.0中修复，而不是在1.x分支中修复。我没有看到我们无法向后移植的原因。

您要反向移植的代码是此文件https://github.com/apache/storm/pull/2575/files#diff-472112e23a03ec30ae9c55beab542631。随意在https://issues.apache.org/jira上打开一个问题吧。如果您想要处理它，您可以将PR提交给https://github.com/apache/storm/pull。