Some embodiments include a stream consolidation engine in a social networking system. The stream consolidation engine can receive two or more input data streams (e.g., an activity record data stream and an application service output stream) from the social networking system. The stream consolidation engine can merge an activity record from the activity record data stream with at least a data record from the input data streams (e.g., from the activity record data stream or the application service output stream) to create a conglomerate data record. The stream consolidation engine can supplement the conglomerate data record with asynchronous information from a data storage or derivative data computed based on content in or referenced by the conglomerate data record. The stream consolidation engine can publish the conglomerate data record in a consolidated data stream. The consolidated data stream can be substantially synchronous to at least one of the input data streams.