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 826755a9b4f MINOR: improve generic type safety for IQv2 in
metered-store layer (#21683)
add a83dda82ebb KAFKA-20249: Optimize raw value extraction in
headers-aware deserializers (#21706)
No new revisions were added by this update.
Summary of changes:
.../jmh/streams/RawBytesExtractionBenchmark.java | 221 ++++++++++++++++++++-
.../kafka/streams/state/HeadersBytesStore.java | 8 +-
.../AggregationWithHeadersDeserializer.java | 35 +---
.../ChangeLoggingSessionBytesStoreWithHeaders.java | 4 +-
...ngTimestampedKeyValueBytesStoreWithHeaders.java | 14 +-
...gingTimestampedWindowBytesStoreWithHeaders.java | 8 +-
...MeteredTimestampedKeyValueStoreWithHeaders.java | 1 -
.../internals/SessionToHeadersStoreAdapter.java | 2 +-
.../kafka/streams/state/internals/Utils.java | 149 +++++++++++---
.../ValueTimestampHeadersDeserializer.java | 50 +----
.../AggregationWithHeadersDeserializerTest.java | 33 ++-
...ocksDBMigratingSessionStoreWithHeadersTest.java | 6 +-
.../SessionToHeadersStoreAdapterTest.java | 4 +-
.../TimeOrderedSessionStoreUpgradeTest.java | 28 +--
.../kafka/streams/state/internals/UtilsTest.java | 65 +++++-
.../ValueTimestampHeadersDeserializerTest.java | 28 ++-
16 files changed, 485 insertions(+), 171 deletions(-)
