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 58402a6 MINOR: add helpful error message (#11139)
add 3190ebd KAFKA-10542: Migrate KTable mapValues, passthrough, and
source to new Processor API (#11099)
No new revisions were added by this update.
Summary of changes:
.../internals/CogroupedStreamAggregateBuilder.java | 2 +-
.../streams/kstream/internals/KTableImpl.java | 2 +-
.../streams/kstream/internals/KTableMapValues.java | 65 +++++++++--------
.../kstream/internals/KTablePassThrough.java | 33 ++++++---
.../streams/kstream/internals/KTableSource.java | 85 +++++++++++++++-------
.../internals/graph/ProcessorParameters.java | 8 +-
.../internals/InternalTopologyBuilder.java | 8 --
.../kstream/internals/KTableSourceTest.java | 30 ++++++++
.../internals/GlobalStreamThreadTest.java | 13 +++-
9 files changed, 158 insertions(+), 88 deletions(-)
