From 9d53d5883cb9dd2194142030b2dd38c0915279ad Mon Sep 17 00:00:00 2001
From: chrislu <chris.lu@gmail.com>
Date: Thu, 16 Oct 2025 20:27:57 -0700
Subject: [PATCH] Revert "fix: Ensure offset fetch checks SMQ storage as
 fallback"

This reverts commit 5c0f215eb58a1357b82fa6358aaf08478ef8bed7.
---
 weed/mq/kafka/protocol/offset_management.go | 2 --
 1 file changed, 2 deletions(-)

diff --git a/weed/mq/kafka/protocol/offset_management.go b/weed/mq/kafka/protocol/offset_management.go
index def902dc4..58ba7a476 100644
--- a/weed/mq/kafka/protocol/offset_management.go
+++ b/weed/mq/kafka/protocol/offset_management.go
@@ -268,8 +268,6 @@ func (h *Handler) handleOffsetFetch(correlationID uint32, apiVersion uint16, req
 				if off, meta, err := h.fetchOffsetFromSMQ(key); err == nil && off >= 0 {
 					fetchedOffset = off
 					metadata = meta
-					// Load into in-memory cache for future queries
-					_ = h.commitOffset(group, topic.Name, partition, off, meta)
 					glog.V(4).Infof("[OFFSET_FETCH] Found in storage: group=%s topic=%s partition=%d offset=%d",
 						request.GroupID, topic.Name, partition, off)
 				} else {