Skip to content

Commit 7a2ae17

Browse files
authored
Merge pull request #28828 from bashtanov/dm-concurrent-group-migrations
Data Migrations: allow concurrent group migrations
2 parents 31a319b + df26eaa commit 7a2ae17

33 files changed

+1469
-703
lines changed

src/v/cluster/commands.h

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -609,7 +609,7 @@ deserialize(model::record_batch b, commands_type_list<Commands...>) {
609609
v_parser.skip(1);
610610
}
611611

612-
// chose deserializer
612+
// choose deserializer
613613
auto cmd_type = reflection::adl<command_type>{}.from(v_parser);
614614
std::optional<std::variant<internal::deserializer<Commands>...>> ret;
615615
(void)((ret = internal::make_deserializer<Commands>(cmd_type), ret) || ...);

src/v/cluster/data_migrated_resources.h

Lines changed: 0 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -52,8 +52,6 @@ class migrated_resources {
5252
bool is_already_migrated(const consumer_group& cg) const {
5353
return _groups.contains(cg);
5454
}
55-
/// Checks if any group is already migrated
56-
bool is_any_group_migrated() const { return !_groups.empty(); }
5755

5856
private:
5957
void apply_snapshot(

0 commit comments

Comments
 (0)