Message queue consumption prohibition plugin.

[lilai23]

What would you like to be added?

New message queue consumption prohibition plug-in is added to support the consumption prohibition of Kakfa and RocketMQ message queues.

• Intercept and cache consumer instances of Kakfa and RocketMQ
• Supports disabling/resuming consumption at Topic or Client granularity
• Supports dynamic configuration and distribution of consumption-prohibited Topics and switches
• After stopping consumption, the partition or queue corresponding to the Topic needs to be released to other consumers in the same consumer group through the rebalancing mechanism.
• If you subscribe to a Topic by specifying a partition or queue consumption method, and then restart consumption after disabling consumption, you will also need to restore the original partition or queue.
• The order of message consumption is not affected, messages are not missed, and messages are not consumed repeatedly.

Why is this needed?

In some system architecture upgrades or failure scenarios, it is necessary to temporarily stop consumption of message queues to ensure system reliability and stability.