This is an automated email from the ASF dual-hosted git repository.
mjsax pushed a change to branch trunk
in repository https://gitbox.apache.org/repos/asf/kafka.git.
from c67e8bc HOTFIX: fix StateManagerUtilTest and StreamTaskTest failures
(#8247)
add e7f6c1e MINOR: fix ClassCastException handling (#8156)
No new revisions were added by this update.
Summary of changes:
.../processor/internals/RecordCollectorImpl.java | 17 +++
.../streams/processor/internals/SinkNode.java | 16 +--
.../processor/internals/RecordCollectorTest.java | 115 +++++++++++++++++++++
.../streams/processor/internals/SinkNodeTest.java | 58 +----------
4 files changed, 134 insertions(+), 72 deletions(-)
