Skip to content

Commit

Permalink
c/topic_table: additional logging in topics_table
Browse files Browse the repository at this point in the history
Signed-off-by: Michal Maslanka <michal@redpanda.com>
  • Loading branch information
mmaslankaprv committed Oct 30, 2023
1 parent 3f3f79c commit 82f0710
Showing 1 changed file with 22 additions and 0 deletions.
22 changes: 22 additions & 0 deletions src/v/cluster/topic_table.cc
Original file line number Diff line number Diff line change
Expand Up @@ -240,6 +240,14 @@ topic_table::apply(create_partition_cmd cmd, model::offset offset) {

ss::future<std::error_code>
topic_table::apply(move_partition_replicas_cmd cmd, model::offset o) {
vlog(
clusterlog.trace,
"applying move partition replicas command: key: {}, value: {}, "
"with revision: {}",
cmd.key,
cmd.value,
o);

_last_applied_revision_id = model::revision_id(o);
auto tp = _topics.find(model::topic_namespace_view(cmd.key));
if (tp == _topics.end()) {
Expand Down Expand Up @@ -291,6 +299,14 @@ static replicas_revision_map update_replicas_revisions(

ss::future<std::error_code>
topic_table::apply(finish_moving_partition_replicas_cmd cmd, model::offset o) {
vlog(
clusterlog.trace,
"applying finish moving partition replicas command: key: {}, value: {}, "
"with revision: {}",
cmd.key,
cmd.value,
o);

_last_applied_revision_id = model::revision_id(o);
auto tp = _topics.find(model::topic_namespace_view(cmd.key));
if (tp == _topics.end()) {
Expand Down Expand Up @@ -330,6 +346,12 @@ topic_table::apply(finish_moving_partition_replicas_cmd cmd, model::offset o) {
it->second.get_update_revision());
}
p_meta_it->second.last_update_finished_revision = model::revision_id{o};
vlog(
clusterlog.trace,
"finishing {} in progress update: {} with revision: {}",
cmd.key,
it->second,
o);

_updates_in_progress.erase(it);

Expand Down

0 comments on commit 82f0710

Please sign in to comment.