Skip to content
Merged
Changes from all commits
Commits
File filter

Filter by extension

Filter by extension

Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
3 changes: 3 additions & 0 deletions lib/kafka_ex/protocol/fetch.ex
Original file line number Diff line number Diff line change
Expand Up @@ -73,6 +73,9 @@ defmodule KafkaEx.Protocol.Fetch do
defp parse_message_set([last|_] = list, _) do
{:ok, Enum.reverse(list), last.offset}
end
defp parse_message_set(_, << offset :: 64, msg_size :: 32, partial_message_data :: binary >>) when byte_size(partial_message_data) < msg_size do
raise RuntimeError, "Insufficient data fetched at offset #{offset}. Message size is #{msg_size} but only received #{byte_size(partial_message_data)} bytes. Try increasing max_bytes."
end

# handles the single message case and the batch (compression) case
defp append_messages([], list) do
Expand Down