You are viewing a plain text version of this content. The canonical link for it is here.

Posted to commits@kafka.apache.org by mj...@apache.org on 2020/03/07 07:27:34 UTC

[kafka] branch trunk updated (c67e8bc -> e7f6c1e)

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(-)