fix(stream): wrap runnable that is executed in thread pool to catch exception

[ShadowySpirits]

No description provided.

[codecov]

Codecov Report

All modified and coverable lines are covered by tests ✅

Comparison is base (da52ecf) 55.91% compared to head (7560897) 55.92%.

Additional details and impacted files

@@             Coverage Diff              @@
##               main     #923      +/-   ##
============================================
+ Coverage     55.91%   55.92%   +0.01%     
- Complexity     1265     1268       +3     
============================================
  Files           133      133              
  Lines          8534     8534              
  Branches        789      789              
============================================
+ Hits           4772     4773       +1     
  Misses         3327     3327              
+ Partials        435      434       -1     

Components	Coverage Δ
RocketMQ Broker	∅ <ø> (∅)
RocketMQ Common	5.80% <ø> (ø)
RocketMQ Controller	57.39% <ø> (ø)
RocketMQ Proxy	37.28% <ø> (+0.10%)	⬆️
RocketMQ Store	73.60% <ø> (-0.05%)	⬇️
RocketMQ Stream	∅ <ø> (∅)
RocketMQ Metadata	35.44% <ø> (ø)

see 2 files with indirect coverage changes