Entry<String, Collection<KafkaLogEvent>> mapEntry = it.next();
List<KafkaLogEvent> list = (List<KafkaLogEvent>) mapEntry.getValue();
Collections.sort(list);
logFileWriter.append(list);
it.remove();
<BUG>}
exponentialBackoff.reset();</BUG>
} catch (Throwable e) {
LOG.error("Caught exception during save, will try again with backoff.", e);
try {

Entry<String, Collection<KafkaLogEvent>> mapEntry = it.next();
List<KafkaLogEvent> list = (List<KafkaLogEvent>) mapEntry.getValue();
Collections.sort(list);
logFileWriter.append(list);
it.remove();
}
logFileWriter.flush(false);
exponentialBackoff.reset();
} catch (Throwable e) {
LOG.error("Caught exception during save, will try again with backoff.", e);
try {
