This is an automated email from the ASF dual-hosted git repository.
bbejeck pushed a change to branch trunk
in repository https://gitbox.apache.org/repos/asf/kafka.git.
from 13b4ca8 KAFKA-12500: fix memory leak in thread cache (#10355)
add a290c8e KAFKA-3745: Add access to read-only key in value joiner
(#10150)
No new revisions were added by this update.
Summary of changes:
.../org/apache/kafka/streams/kstream/KStream.java | 1322 +++++++++++++++++---
.../kafka/streams/kstream/ValueJoinerWithKey.java | 58 +
.../streams/kstream/internals/AbstractStream.java | 10 +
.../kstream/internals/KStreamGlobalKTableJoin.java | 6 +-
.../streams/kstream/internals/KStreamImpl.java | 152 ++-
.../streams/kstream/internals/KStreamImplJoin.java | 8 +-
.../kstream/internals/KStreamKStreamJoin.java | 10 +-
.../kstream/internals/KStreamKTableJoin.java | 6 +-
.../internals/KStreamKTableJoinProcessor.java | 8 +-
.../internals/graph/BaseJoinProcessorNode.java | 8 +-
.../internals/graph/StreamStreamJoinNode.java | 8 +-
.../streams/kstream/internals/KStreamImplTest.java | 185 ++-
.../KStreamImplValueJoinerWithKeyTest.java | 229 ++++
13 files changed, 1756 insertions(+), 254 deletions(-)
create mode 100644
streams/src/main/java/org/apache/kafka/streams/kstream/ValueJoinerWithKey.java
create mode 100644
streams/src/test/java/org/apache/kafka/streams/kstream/internals/KStreamImplValueJoinerWithKeyTest.java
