This is an automated email from the ASF dual-hosted git repository.
Caideyipi pushed a change to branch
feature/initial-retain-progress-after-unsubscribe
in repository https://gitbox.apache.org/repos/asf/iotdb.git
from 0afdbd51dbd Release parsed tablet snapshots before retained
subscription replay
add ec1077b328f Support retention for snapshot subscription topics
No new revisions were added by this update.
Summary of changes:
.../iotdb/confignode/i18n/ConfigNodeMessages.java | 4 -
.../iotdb/confignode/i18n/ConfigNodeMessages.java | 4 -
.../runtime/heartbeat/PipeHeartbeatParser.java | 21 +++-
.../persistence/subscription/SubscriptionInfo.java | 67 ++++++-----
.../consumer/AlterConsumerGroupProcedure.java | 2 +-
.../subscription/CreateSubscriptionProcedure.java | 4 +-
.../subscription/DropSubscriptionProcedure.java | 3 +-
.../subscription/topic/AlterTopicProcedure.java | 8 +-
.../subscription/topic/DropTopicProcedure.java | 5 +-
.../runtime/heartbeat/PipeHeartbeatParserTest.java | 70 ++++++++++-
.../subscription/SubscriptionInfoTest.java | 52 ++++++++
.../SubscriptionInfoTopicValidationTest.java | 12 +-
.../consumer/DropConsumerProcedureTest.java | 81 +++++++------
.../CreateSubscriptionProcedureTest.java | 87 ++++++-------
.../DropSubscriptionProcedureTest.java | 61 +++++-----
.../subscription/topic/DropTopicProcedureTest.java | 22 ++--
.../agent/SubscriptionConsumerAgent.java | 35 +++---
.../db/subscription/broker/SubscriptionBroker.java | 37 ++++--
.../broker/SubscriptionPrefetchingQueue.java | 4 +-
.../agent/SubscriptionConsumerAgentTest.java | 134 +++++++++++----------
.../SubscriptionRetainedInitialReplayTest.java | 110 ++++++++++++-----
.../meta/consumer/ConsumerGroupMeta.java | 50 ++++----
.../consumer/ConsumerGroupDeSerTest.java | 10 +-
23 files changed, 552 insertions(+), 331 deletions(-)
