Add apache kafka as a library user (as of 3.6)

https://issues.apache.org/jira/browse/KAFKA-15084
ben-manes · Jun 25, 2023 · 3915670 · 3915670
1 parent 59df43e
commit 3915670
Show file tree

Hide file tree

Showing 4 changed files with 5 additions and 4 deletions.
diff --git a/README.md b/README.md
@@ -65,6 +65,7 @@ Powering infrastructure near you:
 * [Cassandra][cassandra]: Manage massive amounts of data, fast
 * [Coherence][coherence]: Mission critical in-memory data grid
 * [Accumulo][accumulo]: A sorted, distributed key/value store
+* [Kafka][kafka]: A distributed event streaming platform
 * [HBase][hbase]: A distributed, scalable, big data store
 * [Apache Solr][solr]: Blazingly fast enterprise search
 * [Infinispan][infinispan]: Distributed in-memory data grid
@@ -138,6 +139,7 @@ Snapshots of the development version are available in
 [spring]: https://docs.spring.io/spring/docs/current/spring-framework-reference/integration.html#cache-store-configuration-caffeine
 [scala-cache]: https://github.com/cb372/scalacache
 [scaffeine]: https://github.com/blemale/scaffeine
+[kafka]: https://kafka.apache.org
 [hbase]: https://hbase.apache.org
 [cassandra]: http://cassandra.apache.org
 [solr]: https://solr.apache.org/

diff --git a/gradle/libs.versions.toml b/gradle/libs.versions.toml
@@ -8,7 +8,7 @@ bouncycastle = "1.70"
 cache2k = "2.6.1.Final"
 caffeine = "3.1.6"
 checker-framework = "3.35.0"
-checkstyle = "10.12.0"
+checkstyle = "10.12.1"
 coherence = "22.06.2"
 commons-collections4 = "4.4"
 commons-compress = "1.23.0"

diff --git a/simulator/src/main/java/com/github/benmanes/caffeine/cache/simulator/Simulator.java b/simulator/src/main/java/com/github/benmanes/caffeine/cache/simulator/Simulator.java
@@ -137,7 +137,7 @@ private ImmutableList<PolicyActor> getPolicyActors(Set<Characteristic> character
   }
 
   /** Throws the underlying cause for the simulation failure. */
-  private void throwError(ImmutableList<PolicyActor> policies, RuntimeException e) {
+  private void throwError(Iterable<PolicyActor> policies, RuntimeException e) {
     if (!Thread.currentThread().isInterrupted()) {
       throw e;
     }

diff --git a/...c/main/java/com/github/benmanes/caffeine/cache/simulator/policy/two_queue/QdlpPolicy.java b/...c/main/java/com/github/benmanes/caffeine/cache/simulator/policy/two_queue/QdlpPolicy.java
@@ -144,19 +144,18 @@ private void evict() {
     int freq = candidate.frequency;
     candidate.frequency = 0;
     candidate.remove();
+    sizeFifo--;
 
     if (freq >= moveToMainThreshold) {
       evictFromMain();
       candidate.appendToTail(headMain);
       candidate.type = QueueType.MAIN;
       sizeMain++;
-      sizeFifo--;
     } else {
       candidate.appendToTail(headGhost);
       candidate.type = QueueType.GHOST;
       candidate.frequency = 0;
       sizeGhost++;
-      sizeFifo--;
 
       if (sizeGhost > maxGhost) {
         var ghost = headGhost.next;