enhance: broadcast with event-based notification

[chyezh]

issue: #38399

• broadcast message can carry multi resource key now.
• implement event-based notification for broadcast messages
• broadcast message use broadcast id as a unique identifier in message
• broadcasted message on vchannels keep the broadcasted vchannel now.
• broadcasted message and broadcast message have a common broadcast header now.

[sre-ci-robot]

[APPROVALNOTIFIER] This PR is NOT APPROVED

This pull-request has been approved by: chyezh
To complete the pull request process, please assign czs007 after the PR has been reviewed.
You can assign the PR to them by writing /assign @czs007 in a comment when ready.

The full list of commands accepted by this bot can be found here.

Needs approval from an approver in each of these files:

• OWNERS

Approvers can indicate their approval by writing /approve in a comment
Approvers can cancel approval by writing /approve cancel in a comment

[mergify]

@chyezh E2e jenkins job failed, comment /run-cpu-e2e can trigger the job again.

[mergify]

@chyezh go-sdk check failed, comment rerun go-sdk can trigger the job again.

[codecov]

Codecov Report

Attention: Patch coverage is 86.64495% with 123 lines in your changes missing coverage. Please review.

Project coverage is 81.05%. Comparing base (7476eb3) to head (d75e801).
Report is 7 commits behind head on master.

Files with missing lines	Patch %	Lines
...nternal/streamingcoord/server/service/broadcast.go	23.33%	21 Missing and 2 partials ⚠️
pkg/streaming/util/message/message_impl.go	44.44%	11 Missing and 9 partials ⚠️
...al/streamingcoord/client/broadcast/grpc_watcher.go	85.03%	16 Missing and 3 partials ⚠️
...treamingcoord/client/broadcast/watcher_resuming.go	87.25%	11 Missing and 2 partials ⚠️
...amingcoord/server/broadcaster/broadcast_manager.go	92.50%	6 Missing and 3 partials ⚠️
...server/service/broadcast/broadcast_watch_server.go	88.05%	6 Missing and 2 partials ⚠️
pkg/streaming/util/message/broadcast.go	88.52%	6 Missing and 1 partial ⚠️
...ernal/streamingcoord/server/broadcaster/watcher.go	90.32%	6 Missing ⚠️
pkg/log/with_logger.go	44.44%	3 Missing and 2 partials ⚠️
pkg/streaming/util/message/builder.go	66.66%	1 Missing and 3 partials ⚠️
... and 4 more

Additional details and impacted files

@@             Coverage Diff             @@
##           master   #39522       +/-   ##
===========================================
+ Coverage   69.56%   81.05%   +11.49%     
===========================================
  Files         300     1418     +1118     
  Lines       26986   199595   +172609     
===========================================
+ Hits        18773   161788   +143015     
- Misses       8213    32096    +23883     
- Partials        0     5711     +5711     

Components	Coverage Δ
Client	79.50% <ø> (∅)
Core	69.58% <ø> (+0.01%)	⬆️
Go	82.98% <86.49%> (∅)

Files with missing lines	Coverage Δ
internal/coordinator/coordclient/registry.go	91.17% <ø> (ø)
internal/distributed/streaming/append.go	74.19% <ø> (ø)
internal/distributed/streaming/broadcast.go	100.00% <100.00%> (ø)
internal/distributed/streaming/streaming.go	100.00% <ø> (ø)
internal/distributed/streaming/wal.go	64.86% <100.00%> (ø)
internal/metastore/catalog.go	100.00% <ø> (ø)
internal/metastore/kv/streamingcoord/kv_catalog.go	79.31% <100.00%> (ø)
internal/rootcoord/broadcast_task.go	9.61% <ø> (ø)
internal/streamingcoord/client/client.go	97.01% <100.00%> (ø)
internal/streamingcoord/client/client_impl.go	81.81% <100.00%> (ø)
... and 24 more

... and 1085 files with indirect coverage changes

[mergify]

@chyezh E2e jenkins job failed, comment /run-cpu-e2e can trigger the job again.

[mergify]

@chyezh E2e jenkins job failed, comment /run-cpu-e2e can trigger the job again.

[mergify]

@chyezh E2e jenkins job failed, comment /run-cpu-e2e can trigger the job again.

[chyezh]

/run-cpu-e2e