Fetch multiple messages from disk

I am getting the error for final stage.

Here is the my code: codecrafter/build-your-own-kafka/app/api/fetch/fetch_response.go at main · mingo023/codecrafter · GitHub

I save we had new changes for byte count calculation in PartitionResponse decoding fix: adjust byte count calculation in PartitionResponse decoding · codecrafters-io/kafka-tester@b097661 · GitHub. I believe it should be a problem.

Could anyone help me to figure out the problems?

Hey @mingo023, there might be a few things at play. The first one I noticed is that .compact_records_length is incorrect.

It should represent the number of bytes in the raw RecordBatch , not the length of the RecordBatch array.

Let me know if you’d like further clarification!

1 Like

This topic was automatically closed 5 days after the last reply. New replies are no longer allowed.