Я новичок в Storm and Trident. Я написал носик (использовал ядро ​​​​Storm) для чтения из СУБД. Я переопределяю метод open() BaseRichSpout public void open(Map map, TopologyContext topologyContext, SpoutOutputCollector spoutOutputCollector)...