Details
-
Bug
-
Status: Resolved
-
Major
-
Resolution: Fixed
-
None
-
None
-
None
Description
Currently, if we encounter any IO error while writing to a kafka log, we simply log the error and continue. However, this kind of errors could leave the log in a corrupted state (e.g., only part of a message is added to the log). When this happens, we should stop accepting new requests and force kafka to shutdown. Once kafka is restarted, log recovery can clean up any corrupted log.