Enhance model health notifications by registering, removing, and monitoring message events.

[jsRuner]

Description

Enhance model health notifications by registering, removing, and monitoring message events.

How Has This Been Tested?

• config .env kafka setting
• setup dbgpt
• add model or stop model
• view kafka

Snapshots:

Include snapshots for easier review.

Checklist:

• My code follows the style guidelines of this project
• I have already rebased the commits and make the commit message conform to the project standard.
• I have performed a self-review of my own code
• I have commented my code, particularly in hard-to-understand areas
• I have made corresponding changes to the documentation
• Any dependent changes have been merged and published in downstream modules

[fangyinc]

@jsRuner Thanks. But there are some issues that need to be discussed.
I think we can consider introducing an event notification interface instead of a specific implementation. And the registry is a very lightweight module and should not directly usekafka-python.

[jsRuner]

@jsRuner Thanks. But there are some issues that need to be discussed. I think we can consider introducing an event notification interface instead of a specific implementation. And the registry is a very lightweight module and should not directly usekafka-python.

@jsRuner Thanks. But there are some issues that need to be discussed. I think we can consider introducing an event notification interface instead of a specific implementation. And the registry is a very lightweight module and should not directly usekafka-python.

Okay, I'll think about it again. My original intention is to use DB-GPT as a kernel for external programs to utilize. However, the model may be in an unhealthy state, so it is more stable to determine its availability through a message queue