Fix the kafka panic when sending the message to a closed channel

[SimFG]

issue: #24767

Here the isClosed variable is used instead of select deliveryChan. Because:

If there is a lot of unprocessed information in the kafka producer, it will lead to a longer flush time, and the deliveryChan will be closed and delayed, so there is still a risk of panic, so here when the producer close method is called, first set the isClosed variable. And before send, firstly judge the value of isClosed

[mergify]

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

[mergify]

@SimFG ut workflow job failed, comment rerun ut can trigger the job again.

[SimFG]

rerun ut

[mergify]

@SimFG ut workflow job failed, comment rerun ut can trigger the job again.

[SimFG]

rerun ut

[mergify]

@SimFG ut workflow job failed, comment rerun ut can trigger the job again.

[mergify]

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

[xiaofan-luan]

/lgtm
/approve

[SimFG]

rerun ut

[mergify]

@SimFG ut workflow job failed, comment rerun ut can trigger the job again.

[mergify]

@SimFG ut workflow job failed, comment rerun ut can trigger the job again.

[mergify]

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

[SimFG]

rerun ut

[mergify]

@SimFG ut workflow job failed, comment rerun ut can trigger the job again.

[SimFG]

rerun ut

[mergify]

@SimFG ut workflow job failed, comment rerun ut can trigger the job again.

[SimFG]

rerun ut

[mergify]

@SimFG ut workflow job failed, comment rerun ut can trigger the job again.

[SimFG]

rerun ut

[mergify]

@SimFG ut workflow job failed, comment rerun ut can trigger the job again.

[SimFG]

rerun ut

[mergify]

@SimFG ut workflow job failed, comment rerun ut can trigger the job again.

[SimFG]

rerun ut

[mergify]

@SimFG ut workflow job failed, comment rerun ut can trigger the job again.

[codecov]

Codecov Report

Merging #25116 (e23dfbd) into 2.2.0 (e09da3b) will decrease coverage by 0.04%.
The diff coverage is n/a.

@@            Coverage Diff             @@
##            2.2.0   #25116      +/-   ##
==========================================
- Coverage   80.66%   80.62%   -0.04%     
==========================================
  Files         761      761              
  Lines      107554   107554              
==========================================
- Hits        86757    86716      -41     
- Misses      17478    17509      +31     
- Partials     3319     3329      +10     

see 17 files with indirect coverage changes

[xiaofan-luan]

/lgtm
/approve

[sre-ci-robot]

[APPROVALNOTIFIER] This PR is APPROVED

This pull-request has been approved by: SimFG, xiaofan-luan

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

The pull request process is described here

Needs approval from an approver in each of these files:

• internal/mq/msgstream/OWNERS [xiaofan-luan]
• internal/querynode/OWNERS [xiaofan-luan]

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