jinyongchoi commented on code in PR #15495:
URL: https://github.com/apache/kafka/pull/15495#discussion_r1527393749
##########
docs/streams/developer-guide/memory-mgmt.html:
##########
@@ -151,6 +151,10 @@
Serdes.Long())
.withCachingEnabled();</code></pre>
<p>Record caches are not supported for <a class="reference internal"
href="processor-api.html#streams-developer-guide-state-store-versioned"><span
class="std std-ref">versioned state stores</span></a>.</p>
+ <p><strong>Caution:</strong> When using <code class="docutils
literal"><span class="pre">withCachingEnabled()</span></code>,
+ if you <code class="docutils literal"><span
class="pre">delete()</span></code> a key from the Store while iterating(e.g.,
<code class="docutils literal"><span
class="pre">KeyValueIterator</span></code>) through the keys,
Review Comment:
> Cannot remember from the ticket, but was this limited to deletes, or also
updates?
Yes, that's correct.
This affects the snapshot created in store.all(), causing it to read the
values from rocksdb before the cache is flushed.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
