Renkai Ge created STORM-1010: -------------------------------- Summary: Each KafkaBolt could have a specified properties. Key: STORM-1010 URL: https://issues.apache.org/jira/browse/STORM-1010 Project: Apache Storm Issue Type: Improvement Reporter: Renkai Ge Assignee: Renkai Ge Priority: Minor
Now KafkaBolt producer properties could only be set by conf.put(KafkaBolt.KAFKA_BROKER_PROPERTIES, props); which means all bolts in a topology use the same version of properties. A KafkaBolt may need it's own properties sometimes. -- This message was sent by Atlassian JIRA (v6.3.4#6332)