apache / rocketmq

Apache RocketMQ is a cloud native messaging and streaming platform, making it simple to build event-driven applications.
https://rocketmq.apache.org/
Apache License 2.0
21.14k stars 11.65k forks source link

[Enhancement] Add IP circuit breaker enhancement #8492

Open lvxiao1 opened 2 months ago

lvxiao1 commented 2 months ago

Before Creating the Enhancement Request

Summary

When deploying with Kubernetes, changes in broker IP cause the persistAllConsumerOffset process to take excessively long, blocking the updateTopicRouteInfoFromNameServer scheduling task. This requires a restart of the client to immediately restore normal functionality.

Motivation

  1. schedule Executor is single image
  2. Each loop requires a 2-second timeout, which means it takes 2 seconds for one queue. For 30 queues, it would take one minute. image image

Logging for analytics tracking or instrumentation image

Describe the Solution You'd Like

Add IP circuit breaker enhancement

Describe Alternatives You've Considered

none

Additional Context

No response

yx9o commented 1 month ago

Hi @lvxiao1 , would you like to submit a PR to support it?