Based on what I see in the code, kafka-spout keeps the failed messages in memory buffer.
Would not these failed messages be lost in case of process or machine failure? https://github.com/apache/storm/blob/master/external/storm-kafka/src/jvm/storm/kafka/PartitionManager.java#L206-L221 Is there anything done to make it more resilient?
