liangxp created STORM-3277: ------------------------------ Summary: Flux ues in storm-kafka-client not work? Key: STORM-3277 URL: https://issues.apache.org/jira/browse/STORM-3277 Project: Apache Storm Issue Type: Bug Components: Flux, storm-kafka-client Affects Versions: 1.2.2 Reporter: liangxp
I use yaml like this : {code:java} //代码占位符 # Topology定义 name: "testTopology" config: topology.workers: 1 components: - id: "spoutConfigBuilder" className: "org.apache.storm.kafka.spout.KafkaSpoutConfig$Builder" #contructorArgs 是一个列表,其元素是对象 constructorArgs: # bootstrapServers - "10.7.3.45:9092" # topics - ["test-topic"] #查找class中setter函数进行set此propertie name对应值 properties: - name: "firstPollOffsetStrategy" value: EARLIEST - name: "offsetCommitPeriodMs" value: 200 #配置方法是属性和构造函数的参数 configMethods: - name: "setProp" args: - { "key.deserializer": "org.apache.kafka.common.serialization.StringDeserializer", "value.deserializer": "org.apache.kafka.common.serialization.StringDeserializer", "max.partition.fetch.bytes": 200, "group.id": "kafkaSpoutTestGroup_test", } - id: "spoutConfig" className: "org.apache.storm.kafka.spout.KafkaSpoutConfig" constructorArgs: - ref: "spoutConfigBuilder" # spout定义 spouts: - id: "spout-1" className: "org.apache.storm.kafka.spout.KafkaSpout" parallelism: 1 constructorArgs: - ref: "spoutConfig" # bolt定义 bolts: - id: "bolt-1" className: "com.crfchina.stream.test.OneBolt" parallelism: 1 - id: "bolt-2" className: "com.crfchina.stream.test.TwoBolt" parallelism: 1 # stream定义 streams: - name: "spout-1 --> bolt-1" #name暂时未用上(可以在logging,UI等中作为placeholder) from: "spout-1" to: "bolt-1" grouping: type: SHUFFLE args: ["text"] - name: "bolt-1 --> bolt2" from: "bolt-1" to: "bolt-2" grouping: type: SHUFFLE {code} the error is cannot find " {code:java} org.apache.storm.kafka.spout.KafkaSpoutConfig$Builder{code} " arguments method -- This message was sent by Atlassian JIRA (v7.6.3#76005)