rabbit_stream_coordinator: Handle new return of log overview
This commit is contained in:
parent
517270025f
commit
16ca652939
|
@ -1249,7 +1249,10 @@ get_replica_tail(Node, Conf) ->
|
||||||
{error, nodedown};
|
{error, nodedown};
|
||||||
{error, _} = Err ->
|
{error, _} = Err ->
|
||||||
Err;
|
Err;
|
||||||
|
#{epoch_offsets := Offsets} ->
|
||||||
|
{ok, select_highest_offset(Offsets)};
|
||||||
{_Range, Offsets} ->
|
{_Range, Offsets} ->
|
||||||
|
%% Backwards compatibility clause
|
||||||
{ok, select_highest_offset(Offsets)}
|
{ok, select_highest_offset(Offsets)}
|
||||||
end.
|
end.
|
||||||
|
|
||||||
|
|
Loading…
Reference in New Issue