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 05b2361 KAFKA-9445: Allow adding changes to allow serving from a
specific partition (#7984)
add 6b86af3 KAFKA-7658: Add KStream#toTable to the Streams DSL (#7985)
No new revisions were added by this update.
Summary of changes:
.../org/apache/kafka/streams/kstream/KStream.java | 69 +++
.../streams/kstream/internals/KStreamImpl.java | 103 ++++
...leProcessorNode.java => StreamToTableNode.java} | 47 +-
.../streams/kstream/internals/KStreamImplTest.java | 632 ++++++++++++++++++++-
4 files changed, 824 insertions(+), 27 deletions(-)
copy
streams/src/main/java/org/apache/kafka/streams/kstream/internals/graph/{TableProcessorNode.java
=> StreamToTableNode.java} (56%)
