fix potential panic due to race condition and add slow consumer handling in TriggerSubscriber

fix potential panic due to race condition and add slow consumer handling in TriggerSubscriber #4921