(kafka) branch 4.3 updated: MINOR: Simplify inheritance for MeteredTimestampedWindowStoreWithHeaders (#21966)

[mjsax]

This is an automated email from the ASF dual-hosted git repository.

mjsax pushed a commit to branch 4.3
in repository https://gitbox.apache.org/repos/asf/kafka.git


The following commit(s) were added to refs/heads/4.3 by this push:
     new fee016cedec MINOR: Simplify inheritance for 
MeteredTimestampedWindowStoreWithHeaders (#21966)
fee016cedec is described below

commit fee016cedec28acfccd1ee5702bcf28d43d97e0d
Author: Uladzislau Blok <123193120+uladzislaub...@users.noreply.github.com>
AuthorDate: Sun Apr 5 04:36:30 2026 +0200

    MINOR: Simplify inheritance for MeteredTimestampedWindowStoreWithHeaders 
(#21966)
    
    Reviewers: Matthias J. Sax <matth...@confluent.io>
---
 .../internals/MeteredTimestampedKeyValueStoreWithHeaders.java    | 4 ++--
 .../internals/MeteredTimestampedWindowStoreWithHeaders.java      | 9 ++-------
 .../apache/kafka/streams/state/internals/MeteredWindowStore.java | 2 +-
 3 files changed, 5 insertions(+), 10 deletions(-)

diff --git 
a/streams/src/main/java/org/apache/kafka/streams/state/internals/MeteredTimestampedKeyValueStoreWithHeaders.java
 
b/streams/src/main/java/org/apache/kafka/streams/state/internals/MeteredTimestampedKeyValueStoreWithHeaders.java
index f3865cfc641..d263507a332 100644
--- 
a/streams/src/main/java/org/apache/kafka/streams/state/internals/MeteredTimestampedKeyValueStoreWithHeaders.java
+++ 
b/streams/src/main/java/org/apache/kafka/streams/state/internals/MeteredTimestampedKeyValueStoreWithHeaders.java
@@ -657,7 +657,7 @@ public class MeteredTimestampedKeyValueStoreWithHeaders<K, 
V>
         throw new 
UnsupportedOperationException("MeteredTimestampedKeyValueStoreWithHeaders 
required to pass in Headers when serializing a key.");
     }
 
-    protected Bytes serializeKey(final K key, final Headers headers) {
+    private Bytes serializeKey(final K key, final Headers headers) {
         return Bytes.wrap(serdes.rawKey(key, headers));
     }
 
@@ -666,7 +666,7 @@ public class MeteredTimestampedKeyValueStoreWithHeaders<K, 
V>
         throw new 
UnsupportedOperationException("MeteredTimestampedKeyValueStoreWithHeaders 
required to pass in Headers when deserializing a key.");
     }
 
-    protected K deserializeKey(final byte[] rawKey, final Headers headers) {
+    private K deserializeKey(final byte[] rawKey, final Headers headers) {
         return serdes.keyFrom(rawKey, headers);
     }
 }
\ No newline at end of file
diff --git 
a/streams/src/main/java/org/apache/kafka/streams/state/internals/MeteredTimestampedWindowStoreWithHeaders.java
 
b/streams/src/main/java/org/apache/kafka/streams/state/internals/MeteredTimestampedWindowStoreWithHeaders.java
index 9d5a9ffb4d7..a3803316be6 100644
--- 
a/streams/src/main/java/org/apache/kafka/streams/state/internals/MeteredTimestampedWindowStoreWithHeaders.java
+++ 
b/streams/src/main/java/org/apache/kafka/streams/state/internals/MeteredTimestampedWindowStoreWithHeaders.java
@@ -497,16 +497,11 @@ public class MeteredTimestampedWindowStoreWithHeaders<K, 
V>
         return false;
     }
 
-    protected Bytes serializeKey(final K key, final Headers headers) {
+    private Bytes serializeKey(final K key, final Headers headers) {
         return Bytes.wrap(serdes.rawKey(key, headers));
     }
 
-    @Override
-    protected K deserializeKey(final byte[] rawKey) {
-        throw new 
UnsupportedOperationException("MeteredTimestampedWindowStoreWithHeaders 
required to pass in Headers when deserializing a key.");
-    }
-
-    protected K deserializeKey(final byte[] rawKey, final Headers headers) {
+    private K deserializeKey(final byte[] rawKey, final Headers headers) {
         return serdes.keyFrom(rawKey, headers);
     }
 
diff --git 
a/streams/src/main/java/org/apache/kafka/streams/state/internals/MeteredWindowStore.java
 
b/streams/src/main/java/org/apache/kafka/streams/state/internals/MeteredWindowStore.java
index cfc3f90ac24..ede391e93bc 100644
--- 
a/streams/src/main/java/org/apache/kafka/streams/state/internals/MeteredWindowStore.java
+++ 
b/streams/src/main/java/org/apache/kafka/streams/state/internals/MeteredWindowStore.java
@@ -540,7 +540,7 @@ public class MeteredWindowStore<K, V>
         return Bytes.wrap(serdes.rawKey(key, internalContext.headers()));
     }
 
-    protected K deserializeKey(final byte[] rawKey) {
+    private K deserializeKey(final byte[] rawKey) {
         return serdes.keyFrom(rawKey, internalContext.headers());
     }