(kafka) branch trunk updated: MINOR: Fix bug where dslStoreFormat is non-null and always set to HEADERS (#21777)

[bbejeck]

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

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


The following commit(s) were added to refs/heads/trunk by this push:
     new 8426afcb6a6 MINOR: Fix bug where dslStoreFormat is non-null and always 
set to HEADERS (#21777)
8426afcb6a6 is described below

commit 8426afcb6a64980216e306fa7fefa2f944a22dab
Author: Bill Bejeck <bbej...@apache.org>
AuthorDate: Mon Mar 16 15:08:41 2026 -0400

    MINOR: Fix bug where dslStoreFormat is non-null and always set to HEADERS 
(#21777)
    
    This PR fixes a bug identified during reviews but was missed addressing
    comments
    
      Bug: always returns HEADERS when dslStoreFormat() is non-null `final
    DslStoreFormat storeFormat = dslStoreFormat() == null ?
    DslStoreFormat.PLAIN : DslStoreFormat.HEADERS;`
    
      Fix:    `final DslStoreFormat storeFormat = dslStoreFormat() == null ?
    DslStoreFormat.PLAIN : dslStoreFormat();`
    
    Reviewers: TengYao Chi <frankvi...@apache.org>
---
 .../kafka/streams/kstream/internals/SessionStoreMaterializer.java       | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git 
a/streams/src/main/java/org/apache/kafka/streams/kstream/internals/SessionStoreMaterializer.java
 
b/streams/src/main/java/org/apache/kafka/streams/kstream/internals/SessionStoreMaterializer.java
index 5f1f9e409e7..e89c46141d5 100644
--- 
a/streams/src/main/java/org/apache/kafka/streams/kstream/internals/SessionStoreMaterializer.java
+++ 
b/streams/src/main/java/org/apache/kafka/streams/kstream/internals/SessionStoreMaterializer.java
@@ -60,7 +60,7 @@ public class SessionStoreMaterializer<K, V> extends 
MaterializedStoreFactory<K,
 
     @Override
     public  StoreBuilder<SessionStoreWithHeaders<K, V>> builder() {
-        final DslStoreFormat storeFormat = dslStoreFormat() == null ? 
DslStoreFormat.PLAIN : DslStoreFormat.HEADERS;
+        final DslStoreFormat storeFormat = dslStoreFormat() == null ? 
DslStoreFormat.PLAIN : dslStoreFormat();
         final SessionBytesStoreSupplier supplier = 
materialized.storeSupplier() == null
                 ? dslStoreSuppliers().sessionStore(new DslSessionParams(
                         materialized.storeName(),