Hi, I am creating a topology in flux, using yaml. I am trying to get the latest offset from Kafka so that storm can process only the latest messages, for that, I am using static factory methods. Here is my topology components:
- id: "startingOffsetTime" className: "kafka.api.OffsetRequest" factory: "LatestTime" - id: "spoutConfig" className: "org.apache.storm.kafka.SpoutConfig" constructorArgs: - ref: "zkHosts" - "blockdata" - "" - "myId" properties: - name: "scheme" ref: "stringMultiScheme" - name: "ignoreZkOffsets" value: true - name: "startOffsetTime" ref: "startingOffsetTime" But I am getting error msg: Cannot create property=factory for JavaBean=org.apache.storm.flux.model.BeanDef@4de5031f; Unable to find property 'factory' on class: org.apache.storm.flux.model.BeanDef Caused by: org.yaml.snakeyaml.error.YAMLException: Cannot create property=factory for JavaBean=org.apache.storm.flux.model.BeanDef@4de5031f; Unable to find property 'factory' on class: org.apache.storm.flux.model.BeanDef Please help. I am stuck on this for days now. Caused by: org.yaml.snakeyaml.error.YAMLException: Cannot create property=factory for JavaBean=org.apache.storm.flux.model.BeanDef@4de5031f; Unable to find property 'factory' on class: org.apache.storm.flux.model.BeanDef Cannot create property=factory for JavaBean=org.apache.storm.flux.model.BeanDef@4de5031f; Unable to find property 'factory' on class: org.apache.storm.flux.model.BeanDef Cannot create property=factory for JavaBean=org.apache.storm.flux.model.BeanDef@4de5031f; Unable to find property 'factory' on class: org.apache.storm.flux.model.BeanDef -- Regards, Obaid Ur Rehman -- Regards, Obaid Ur Rehman
