[ https://issues.apache.org/jira/browse/KAFKA-2592?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14933694#comment-14933694 ]
Guozhang Wang commented on KAFKA-2592: -------------------------------------- Yes, this is not a correctness issue since we do not have exactly-once anyways, but the likelihood of having data duplicates will be larger in this case. > Stop Writing the Change-log in store.put() / delete() for Non-transactional > Store > --------------------------------------------------------------------------------- > > Key: KAFKA-2592 > URL: https://issues.apache.org/jira/browse/KAFKA-2592 > Project: Kafka > Issue Type: Sub-task > Reporter: Guozhang Wang > Assignee: Yasuhiro Matsuda > Fix For: 0.9.0.0 > > > Today we keep a dirty threshold and try to send to change-log in store.put() > / delete() when the threshold has been exceeded. Doing this will largely > increase the likelihood of inconsistent state upon unclean shutdown. -- This message was sent by Atlassian JIRA (v6.3.4#6332)