This is an automated email from the ASF dual-hosted git repository.
vvcephei pushed a change to branch trunk
in repository https://gitbox.apache.org/repos/asf/kafka.git.
from 7e66848 MINOR: Restore stream-table duality description (#8995)
add 888f83c KAFKA-10249: don't try to read un-checkpointed offsets of in-memory stores
(#8996)
No new revisions were added by this update.
Summary of changes:
.../processor/internals/ProcessorStateManager.java | 8 +++
.../processor/internals/StateManagerUtil.java | 21 +++---
.../internals/ProcessorStateManagerTest.java | 79 ++++++++++++++++++++--
.../processor/internals/StateManagerUtilTest.java | 29 ++++++++
4 files changed, 123 insertions(+), 14 deletions(-)
|