diff options
| author | Chris Lu <chrislusf@users.noreply.github.com> | 2025-10-17 22:11:50 -0700 |
|---|---|---|
| committer | GitHub <noreply@github.com> | 2025-10-17 22:11:50 -0700 |
| commit | 97f30287821e1c49b816f2e4c05be46728b06a0b (patch) | |
| tree | 1169d6e45c06698fc4081b8cfc27f2d4d2e98684 /weed/mq/kafka/protocol/fetch_partition_reader.go | |
| parent | 8d63a9cf5f011baa4b86372b4f28b7179b9dc9cb (diff) | |
| download | seaweedfs-97f30287821e1c49b816f2e4c05be46728b06a0b.tar.xz seaweedfs-97f30287821e1c49b816f2e4c05be46728b06a0b.zip | |
Clean up logs and deprecated functions (#7339)
* less logs
* fix deprecated grpc.Dial
Diffstat (limited to 'weed/mq/kafka/protocol/fetch_partition_reader.go')
| -rw-r--r-- | weed/mq/kafka/protocol/fetch_partition_reader.go | 16 |
1 files changed, 0 insertions, 16 deletions
diff --git a/weed/mq/kafka/protocol/fetch_partition_reader.go b/weed/mq/kafka/protocol/fetch_partition_reader.go index 0117e3809..6583c6489 100644 --- a/weed/mq/kafka/protocol/fetch_partition_reader.go +++ b/weed/mq/kafka/protocol/fetch_partition_reader.go @@ -2,7 +2,6 @@ package protocol import ( "context" - "fmt" "sync" "time" @@ -120,21 +119,9 @@ func (pr *partitionReader) serveFetchRequest(ctx context.Context, req *partition startTime := time.Now() result := &partitionFetchResult{} - // Log request START with full details - glog.Infof("[%s] FETCH_START %s[%d]: offset=%d maxBytes=%d maxWait=%dms correlationID=%d", - pr.connCtx.ConnectionID, pr.topicName, pr.partitionID, req.requestedOffset, req.maxBytes, req.maxWaitMs, req.correlationID) - defer func() { result.fetchDuration = time.Since(startTime) - // Log request END with results - resultStatus := "EMPTY" - if len(result.recordBatch) > 0 { - resultStatus = fmt.Sprintf("DATA(%dB)", len(result.recordBatch)) - } - glog.Infof("[%s] FETCH_END %s[%d]: offset=%d result=%s hwm=%d duration=%.2fms", - pr.connCtx.ConnectionID, pr.topicName, pr.partitionID, req.requestedOffset, resultStatus, result.highWaterMark, result.fetchDuration.Seconds()*1000) - // Send result back to client select { case req.resultChan <- result: @@ -189,9 +176,6 @@ func (pr *partitionReader) serveFetchRequest(ctx context.Context, req *partition pr.connCtx.ConnectionID, pr.topicName, pr.partitionID, req.requestedOffset, hwm) result.recordBatch = []byte{} } else { - // Log successful fetch with details - glog.Infof("[%s] FETCH SUCCESS %s[%d]: offset %d->%d (hwm=%d, bytes=%d)", - pr.connCtx.ConnectionID, pr.topicName, pr.partitionID, req.requestedOffset, newOffset, hwm, len(recordBatch)) result.recordBatch = recordBatch pr.bufferMu.Lock() pr.currentOffset = newOffset |