From 05cd69b6e18c7afa73be0bc8d6623c689724aa10 Mon Sep 17 00:00:00 2001
From: Uladzislau Blok <blokv75@gmail.com>
Date: Sun, 5 Apr 2026 13:29:52 +0200
Subject: [PATCH] CachingKeyValueStore headers propagation

---
 .../kafka/streams/state/internals/CachingKeyValueStore.java     | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/streams/src/main/java/org/apache/kafka/streams/state/internals/CachingKeyValueStore.java b/streams/src/main/java/org/apache/kafka/streams/state/internals/CachingKeyValueStore.java
index 8ef68e0d06c12..d586aa25de8bf 100644
--- a/streams/src/main/java/org/apache/kafka/streams/state/internals/CachingKeyValueStore.java
+++ b/streams/src/main/java/org/apache/kafka/streams/state/internals/CachingKeyValueStore.java
@@ -426,7 +426,7 @@ public KeyValueIterator<Bytes, byte[]> all() {
     public <PS extends Serializer<P>, P> KeyValueIterator<Bytes, byte[]> prefixScan(final P prefix, final PS prefixKeySerializer) {
         validateStoreOpen();
         final KeyValueIterator<Bytes, byte[]> storeIterator = wrapped().prefixScan(prefix, prefixKeySerializer);
-        final Bytes from = Bytes.wrap(prefixKeySerializer.serialize(null, prefix));
+        final Bytes from = Bytes.wrap(prefixKeySerializer.serialize(null, internalContext.headers(), prefix));
         final Bytes to = ByteUtils.increment(from);
         final ThreadCache.MemoryLRUCacheBytesIterator cacheIterator = internalContext.cache().range(cacheName, from, to, false);
         return new MergedSortedCacheKeyValueBytesStoreIterator(cacheIterator, storeIterator, true);