Skip to content

Commit

Permalink
kafka: log successful cg init and recovery
Browse files Browse the repository at this point in the history
Signed-off-by: NyaliaLui <[email protected]>
  • Loading branch information
NyaliaLui committed Aug 16, 2023
1 parent 1398228 commit c64efa4
Showing 1 changed file with 7 additions and 1 deletion.
8 changes: 7 additions & 1 deletion src/v/kafka/server/group_manager.cc
Original file line number Diff line number Diff line change
Expand Up @@ -770,6 +770,12 @@ ss::future<> group_manager::do_recover_group(
p->partition->ntp());
}
}

vlog(
klog.info,
"Successfully recovered group: group {}, ntp {}",
group_id,
p->partition->ntp());
}
co_return;
}
Expand Down Expand Up @@ -932,7 +938,7 @@ group::join_group_stages group_manager::join_group(join_group_request&& r) {
_groups.emplace(r.data.group_id, group);
_groups.rehash(0);
is_new_group = true;
vlog(klog.trace, "Created new group {} while joining", r.data.group_id);
vlog(klog.info, "Created new group {} while joining", r.data.group_id);
}

auto ret = group->handle_join_group(std::move(r), is_new_group);
Expand Down

0 comments on commit c64efa4

Please sign in to comment.