add realtime consumer producer