Hi All, I have been looking the codes for ConfiguredBolt and its derivatives. I realized that updateConfig is actually not doing much?
Would you describe how you manage configuration changes might be needed after bolts are initialized and running? for convenience, I copied the code here public void updateConfig(String path, byte[] data) throws IOException { if (data.length != 0) { String name = path.substring(path.lastIndexOf("/") + 1); if (path.startsWith(ConfigurationType.ENRICHMENT.getZookeeperRoot())) { getConfigurations().updateSensorEnrichmentConfig(name, data); reloadCallback(name, ConfigurationType.ENRICHMENT); } else if (ConfigurationType.GLOBAL.getZookeeperRoot().equals(path)) { getConfigurations().updateGlobalConfig(data); reloadCallback(name, ConfigurationType.GLOBAL); } } Thanks,