This is an automated email from the ASF dual-hosted git repository.
Caideyipi pushed a change to branch fix/subscription-broker-self-healing
in repository https://gitbox.apache.org/repos/asf/iotdb.git
from acccd0e34a4 Repair missing subscription brokers from consumer metadata
add 0d2ef238dd6 Fix subscription broker recovery rollback
No new revisions were added by this update.
Summary of changes:
.../agent/SubscriptionBrokerAgent.java | 21 +++
.../agent/SubscriptionConsumerAgent.java | 9 +-
.../broker/ConsensusSubscriptionBroker.java | 35 ++++
.../ConsensusSubscriptionCommitManager.java | 27 ++-
.../ConsensusSubscriptionSetupHandler.java | 53 +++++-
...ubscriptionConsumerAgentBrokerRecoveryTest.java | 57 ++++++
.../ConsensusSubscriptionSetupHandlerTest.java | 205 +++++++++++++++++++++
.../receiver/SubscriptionReceiverV1Test.java | 2 +-
8 files changed, 388 insertions(+), 21 deletions(-)
