我试图通过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
1条答案
按热度按时间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.