Jun Rao created KAFKA-765:
-----------------------------
Summary: Corrupted messages in produce request could shutdown the
broker
Key: KAFKA-765
URL: https://issues.apache.org/jira/browse/KAFKA-765
Project: Kafka
Issue Type: Bug
Components: core
Affects Versions: 0.8
Reporter: Jun Rao
Priority: Blocker
In kafka.log.append(), we convert all IOException to KafkaStorageException.
This will cause the caller to shutdown the broker. However, if there is a
corrupted compressed message, validMessages.assignOffsets() in append() could
also throw an IOException when decompressing the message. In this case, we
shouldn't shut down the broker and should just fail this particular produce
request.
--
This message is automatically generated by JIRA.
If you think it was sent incorrectly, please contact your JIRA administrators
For more information on JIRA, see: http://www.atlassian.com/software/jira
