Methods and products for processing streams of data records using at least one data stream processing program executing on at least one data processing device and communicating with one another through data communication interfaces to form a network of data stream processing programs. In at least one embodiment, a method includes holding and maintaining information to record a configuration history, processing streams of data records with a plurality of data stream processing programs together functioning as a stream processing system, receiving input streams of data records by the data stream processing programs over the data communication interfaces, sending output streams of data records by the data stream processing programs over the data communication interfaces, and interoperating internal data producer/publisher programs with internal data consumer/producer programs in accordance with a current configuration in order to perform the sending and receiving.