Which of the following could be used as sources in a stream processing pipeline? Select two responses.