[ https://issues.apache.org/jira/browse/KAFKA-4379?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15982362#comment-15982362 ]
ASF GitHub Bot commented on KAFKA-4379: --------------------------------------- GitHub user guozhangwang opened a pull request: https://github.com/apache/kafka/pull/2908 KAFKA-4379 Followup: Remove eviction listener from InMemoryLRUCache You can merge this pull request into a Git repository by running: $ git pull https://github.com/guozhangwang/kafka K4379-remove-listener Alternatively you can review and apply these changes as the patch at: https://github.com/apache/kafka/pull/2908.patch To close this pull request, make a commit to your master/trunk branch with (at least) the following in the commit message: This closes #2908 ---- commit 44e1cea3a300b0e05e9574284260b774b852cb4e Author: Guozhang Wang <wangg...@gmail.com> Date: 2017-04-25T02:07:23Z remove eviction listener commit 6343783ec2ffc907ad2b1d25cd764a6e52acc299 Author: Guozhang Wang <wangg...@gmail.com> Date: 2017-04-25T04:50:02Z fix unit test ---- > Remove caching of dirty and removed keys from StoreChangeLogger > --------------------------------------------------------------- > > Key: KAFKA-4379 > URL: https://issues.apache.org/jira/browse/KAFKA-4379 > Project: Kafka > Issue Type: Improvement > Components: streams > Affects Versions: 0.10.1.0 > Reporter: Damian Guy > Assignee: Damian Guy > Priority: Minor > Fix For: 0.10.1.1, 0.10.2.0 > > > The StoreChangeLogger currently keeps a cache of dirty and removed keys and > will batch the changelog records such that we don't send a record for each > update. However, with KIP-63 this is unnecessary as the batching and > de-duping is done by the caching layer. Further, the StoreChangeLogger relies > on context.timestamp() which is likely to be incorrect when caching is enabled -- This message was sent by Atlassian JIRA (v6.3.15#6346)