Check out dataflows in Composable for a quick way to implement these data streams. https://docs.composable.ai/en/latest/03.DataFlows/01.Overvie...