Skip to content

Commit 622dec0

Browse files
committed
Return error if store offset reference is longer than 255 characters
1 parent 0260862 commit 622dec0

File tree

1 file changed

+3
-0
lines changed

1 file changed

+3
-0
lines changed

deps/rabbitmq_stream/src/rabbit_stream_reader.erl

Lines changed: 3 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -3463,6 +3463,9 @@ clean_state_after_stream_deletion_or_failure(MemberPid, Stream,
34633463
{not_cleaned, C2#stream_connection{stream_leaders = Leaders1}, S2}
34643464
end.
34653465

3466+
store_offset(Reference, _, _, C) when is_binary(Reference), byte_size(Reference) > ?MAX_REFERENCE_SIZE ->
3467+
rabbit_log:warning("Reference is too long to store offset: ~p", [byte_size(Reference)]),
3468+
C;
34663469
store_offset(Reference, Stream, Offset, Connection0) ->
34673470
case lookup_leader(Stream, Connection0) of
34683471
{error, Error} ->

0 commit comments

Comments
 (0)