Use Kafka Streams state stores to cache scanner results #382
Labels
domain/vuln-analysis
enhancement
New feature or request
p3
Nice-to-have features
size/M
Medium effort
We currently cache scanner results in-memory using
quarkus-cache
. It is simple and "just works™️".The downside is that cached results will be lost when the vulnerability-analyzer instance is restarted, or a rebalance is happening and partitions are re-assigned between consumer group members.
As an alternative, we can use Kafka Streams' state stores to cache results. Implementation-wise, it will be similar to the stores we already have for retries and batching.
The benefit of state stores is that cache entries will be "backed up" by Kafka changelog topics. So when app instances restart, or partitions get re-assigned, cache entries are not lost.
The text was updated successfully, but these errors were encountered: