Forwarder

[bnayae]

Add buit-in forwarder operations:

• read messages from one stream + storage strategy
• forward it to other streams + storage strategy (can use the Merge operation to broadcast)
• it should be at the message segmentation level (interface contract agnostic)
• in case of a cross cluster (external call) it can do API call (which will handle it at the segmentation level)
  • have HttpClient/Factory as parameter
• Consumer builder should allow filter by origin (ignore copy = default?)