[jira] [Created] (STORM-3277) Flux ues in storm-kafka-client not work?

["liangxp (JIRA)" <ji...@apache.org>]

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)