BrokerStreaming for bualang PHASE I