风暴Kafka-client:1.2.2 kafkaspoutconfig 使用yaml

jw5wzhpr  于 2021-06-06  发布在  Kafka
关注(0)|答案(1)|浏览(339)

我试图通过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的例子?
我正在使用下面的风暴和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
wfveoks0

wfveoks01#

yaml看起来是正确的(假设损坏的缩进是一个复制粘贴错误,否则您需要修复它)。
您受到中修复的错误的影响https://github.com/apache/storm/pull/2575. 它只在storm 2.0.0中修复,而在1.x分支中没有修复。我看不出我们为什么不能支持它。
你想要后端口的代码是这个文件https://github.com/apache/storm/pull/2575/files#diff-472112E23A03EC30AE9C55BEB542631。随时可以在https://issues.apache.org/jira 为了它。如果你想做这件事,你可以提交公关https://github.com/apache/storm/pull.

相关问题