This is an automated email from the ASF dual-hosted git repository.
frankvicky pushed a change to branch trunk
in repository https://gitbox.apache.org/repos/asf/kafka.git
from ff010a402d1 KAFKA-20269 [3/N]: Refactor assignment update for delayed
streams assignments (#21696)
add 10d52734dc1 KAFKA-20205: Refactor serialization and deserialization
code for *WithHeaders types (#21626)
No new revisions were added by this update.
Summary of changes:
.../AggregationWithHeadersDeserializer.java | 30 +----
.../state/internals/HeadersDeserializer.java | 9 +-
.../state/internals/MeteredKeyValueStore.java | 19 ++-
.../internals/MeteredSessionStoreWithHeaders.java | 7 +-
.../internals/MeteredTimestampedKeyValueStore.java | 17 +--
.../internals/MeteredVersionedKeyValueStore.java | 13 +-
.../streams/state/internals/PositionSerde.java | 5 +-
...TimestampedKeyValueStoreBuilderWithHeaders.java | 2 +-
.../TimestampedToHeadersStoreAdapter.java | 28 +----
.../kafka/streams/state/internals/Utils.java | 95 ++++++++++++++-
.../ValueTimestampHeadersDeserializer.java | 22 +---
.../kafka/streams/state/internals/UtilsTest.java | 133 ++++++++++++++++++++-
12 files changed, 264 insertions(+), 116 deletions(-)
