Re: Kafka throw InvalidMessageException and lost data
Do you mind trying out the DumpLogSegment tool on the log segment for the
corrupted topic. That will validate if the log data is corrupted. Also, Is
your test reproducible ? We ran into a similar issue in production but
could not reproduce it.
On Monday, March 18, 2013, Helin Xiang wrote: