diff options
| author | Karl Nilsson <kjnilsson@gmail.com> | 2021-11-17 09:04:35 +0000 |
|---|---|---|
| committer | Karl Nilsson <kjnilsson@gmail.com> | 2021-11-17 09:04:35 +0000 |
| commit | 3b62665b34b29b6f64ae4f7b5d800df10375346d (patch) | |
| tree | b4b13abe139673c7150369624a454fd8d3759550 | |
| parent | e52a127ef9f9011051ecd416ca8730751a15cdc8 (diff) | |
| download | rabbitmq-server-git-3b62665b34b29b6f64ae4f7b5d800df10375346d.tar.gz | |
Stream coordinator: log member deletions
| -rw-r--r-- | deps/rabbit/src/rabbit_stream_coordinator.erl | 2 |
1 files changed, 2 insertions, 0 deletions
diff --git a/deps/rabbit/src/rabbit_stream_coordinator.erl b/deps/rabbit/src/rabbit_stream_coordinator.erl index c07b172b43..7e8069d866 100644 --- a/deps/rabbit/src/rabbit_stream_coordinator.erl +++ b/deps/rabbit/src/rabbit_stream_coordinator.erl @@ -686,6 +686,8 @@ phase_delete_member(StreamId, #{node := Node} = Arg, Conf) -> fun() -> try osiris_server_sup:delete_child(Node, Conf) of ok -> + rabbit_log:info("~s: Member deleted for ~s : on node ~s", + [?MODULE, StreamId, Node]), send_self_command({member_deleted, StreamId, Arg}); _ -> send_action_failed(StreamId, deleting, Arg) |