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 751a8af1f0f KAFKA-14420: Use incrementalAlterConfigs API for syncing
topic configurations in MirrorMaker 2 (KIP-894) (#13373)
add 396536bb5aa KAFKA-12446: Call subtractor before adder if key is the
same (#10747)
No new revisions were added by this update.
Summary of changes:
docs/streams/developer-guide/dsl-api.html | 8 +-
docs/streams/upgrade-guide.html | 20 ++-
.../org/apache/kafka/streams/StreamsConfig.java | 11 +-
.../kstream/internals/ChangedDeserializer.java | 39 ++++-
.../kstream/internals/ChangedSerializer.java | 97 ++++++++++---
.../kstream/internals/KTableRepartitionMap.java | 63 +++++++-
.../kstream/internals/ChangedSerdeTest.java | 109 ++++++++++++++
.../kstream/internals/KTableAggregateTest.java | 158 ++++++++++++++++++++-
.../internals/KTableTransformValuesTest.java | 15 +-
9 files changed, 467 insertions(+), 53 deletions(-)
create mode 100644
streams/src/test/java/org/apache/kafka/streams/kstream/internals/ChangedSerdeTest.java
