[jira] [Created] (KAFKA-3941) Avoid applying eviction listener in InMemoryKeyValueLoggedStore

["Guozhang Wang (JIRA)" <ji...@apache.org>]

Guozhang Wang created KAFKA-3941:
------------------------------------

             Summary: Avoid applying eviction listener in InMemoryKeyValueLoggedStore
                 Key: KAFKA-3941
                 URL: https://issues.apache.org/jira/browse/KAFKA-3941
             Project: Kafka
          Issue Type: Bug
          Components: streams
            Reporter: Guozhang Wang
            Assignee: Guozhang Wang


This is reported by [~norwood].

In {{InMemoryKeyValueLoggedStore}} we set the eviction listener which records the evicted records as deletes in the changelog. However, when restoring the store this listener will then double-writes the delete record, causing the restoration process to fail.

We should defer the listener initialization until the end of the {{init}} call, instead of inside the {{supplier.get}}.



--
This message was sent by Atlassian JIRA
(v6.3.4#6332)