diff options
Diffstat (limited to 'weed/mq/broker/broker_grpc_fetch.go')
| -rw-r--r-- | weed/mq/broker/broker_grpc_fetch.go | 6 |
1 files changed, 0 insertions, 6 deletions
diff --git a/weed/mq/broker/broker_grpc_fetch.go b/weed/mq/broker/broker_grpc_fetch.go index 19024d852..4eb17d4fb 100644 --- a/weed/mq/broker/broker_grpc_fetch.go +++ b/weed/mq/broker/broker_grpc_fetch.go @@ -105,9 +105,6 @@ func (b *MessageQueueBroker) FetchMessage(ctx context.Context, req *mq_pb.FetchM requestedOffset := req.StartOffset // Read messages from LogBuffer (stateless read) - glog.Infof("[FetchMessage] About to read from LogBuffer: topic=%s partition=%v offset=%d maxMessages=%d maxBytes=%d", - t.Name, partition, requestedOffset, maxMessages, maxBytes) - logEntries, nextOffset, highWaterMark, endOfPartition, err := localPartition.LogBuffer.ReadMessagesAtOffset( requestedOffset, maxMessages, @@ -122,9 +119,6 @@ func (b *MessageQueueBroker) FetchMessage(ctx context.Context, req *mq_pb.FetchM nextOffset, endOfPartition, localPartition.LogBuffer.GetLogStartOffset()) } - glog.Infof("[FetchMessage] Read completed: topic=%s partition=%v offset=%d -> %d entries, nextOffset=%d, hwm=%d, eop=%v, err=%v", - t.Name, partition, requestedOffset, len(logEntries), nextOffset, highWaterMark, endOfPartition, err) - if err != nil { // Check if this is an "offset out of range" error errMsg := err.Error() |