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/integration/broker_client_fetch.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/integration/broker_client_fetch.go')
| -rw-r--r-- | weed/mq/kafka/integration/broker_client_fetch.go | 4 |
1 files changed, 0 insertions, 4 deletions
diff --git a/weed/mq/kafka/integration/broker_client_fetch.go b/weed/mq/kafka/integration/broker_client_fetch.go index 25af9e809..016f8ccdf 100644 --- a/weed/mq/kafka/integration/broker_client_fetch.go +++ b/weed/mq/kafka/integration/broker_client_fetch.go @@ -80,10 +80,6 @@ func (bc *BrokerClient) FetchMessagesStateless(ctx context.Context, topic string } } - // CRITICAL DEBUGGING: Log what broker returned - glog.Infof("[FETCH-STATELESS-CLIENT] Broker response for %s[%d] offset %d: messages=%d, nextOffset=%d, hwm=%d, logStart=%d, endOfPartition=%v", - topic, partition, startOffset, len(resp.Messages), resp.NextOffset, resp.HighWaterMark, resp.LogStartOffset, resp.EndOfPartition) - // CRITICAL: If broker returns 0 messages but hwm > startOffset, something is wrong if len(resp.Messages) == 0 && resp.HighWaterMark > startOffset { glog.Errorf("[FETCH-STATELESS-CLIENT] CRITICAL BUG: Broker returned 0 messages for %s[%d] offset %d, but HWM=%d (should have %d messages available)", |