GitHub user guozhangwang opened a pull request:
https://github.com/apache/kafka/pull/1610
KAFKA-3941: Delay eviction listener in InMemoryKeyValueLoggedStore after
restoration
Also move the initialization that restores from changelog to inner stores.
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/guozhangwang/kafka
K3941-avoid-eviction-listener
Alternatively you can review and apply these changes as the patch at:
https://github.com/apache/kafka/pull/1610.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 #1610
----
commit bcf1c8070ded1b65b27e4a71673ecf2a54b5affc
Author: Guozhang Wang <[email protected]>
Date: 2016-07-11T20:48:35Z
Add the listener in InMemoryLRUCache after restoration
commit 02954a2e91aa7e1982d486551d54daa5107fc5b5
Author: Guozhang Wang <[email protected]>
Date: 2016-07-11T21:05:02Z
Merge branch 'trunk' of https://git-wip-us.apache.org/repos/asf/kafka into
K3941-avoid-eviction-listener
commit f9f5d518969b0f5e80aa4aeab9e2c17feec62c5b
Author: Guozhang Wang <[email protected]>
Date: 2016-07-11T22:26:55Z
revert storeSupplier.get() changes
commit f230b38e15d7464a6fd88aca43aacc225a583292
Author: Guozhang Wang <[email protected]>
Date: 2016-07-11T22:32:04Z
revert gradlew changes
----
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does not have this feature
enabled and wishes so, or if the feature is enabled but not working, please
contact infrastructure at [email protected] or file a JIRA ticket
with INFRA.
---
