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)
