Browse Source

Revert "fix: Ensure offset fetch checks SMQ storage as fallback"

This reverts commit 5c0f215eb5.
pull/7329/head
chrislu 4 days ago
parent
commit
9d53d5883c
  1. 2
      weed/mq/kafka/protocol/offset_management.go

2
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 {

Loading…
Cancel
Save