Storm Utils Distributed Lock Spout You need to zookeeper Schedule Job Spout If You may use multi ScheduleJobSpout then can read to duplicated data.