kafka-go
kafka-go copied to clipboard
Fix: skip reading from compacted records
We experience this issue when replaying messages from a compacted topic. For readMessageV2 we actually can receive a batch response with zero header count so this fix will skip the batch until it meet a non-empty one.
This is currently the fix that we applied to our local forked repository we're using now, but we expect to get this merged to get up-to-date with the origin public repository.
Fixes #874
Hi @niafly, thanks for submitting this PR, could you please include tests for these changes?
Hi @niafly do you have any plans to finish this?