diff options
| author | Chris Lu <chris.lu@gmail.com> | 2024-02-05 17:30:20 -0800 |
|---|---|---|
| committer | Chris Lu <chris.lu@gmail.com> | 2024-02-05 17:30:20 -0800 |
| commit | 07028a48648a98e00d1d9990dc30293dcc6835c7 (patch) | |
| tree | 219096530a3ec9c03e9b91d6764e859ba9b4cdb2 | |
| parent | fa72761bb8d77f20b177e0307ecc645c27aef991 (diff) | |
| download | seaweedfs-07028a48648a98e00d1d9990dc30293dcc6835c7.tar.xz seaweedfs-07028a48648a98e00d1d9990dc30293dcc6835c7.zip | |
minor
| -rw-r--r-- | weed/mq/client/pub_client/scheduler.go | 4 |
1 files changed, 2 insertions, 2 deletions
diff --git a/weed/mq/client/pub_client/scheduler.go b/weed/mq/client/pub_client/scheduler.go index d577e77e0..39a659635 100644 --- a/weed/mq/client/pub_client/scheduler.go +++ b/weed/mq/client/pub_client/scheduler.go @@ -166,12 +166,12 @@ func (p *TopicPublisher) doPublishToPartition(job *EachPartitionPublishJob) erro return } publishClient.Err = err - fmt.Printf("publish to %s error: %v\n", publishClient.Broker, err) + fmt.Printf("publish1 to %s error: %v\n", publishClient.Broker, err) return } if ackResp.Error != "" { publishClient.Err = fmt.Errorf("ack error: %v", ackResp.Error) - fmt.Printf("publish to %s error: %v\n", publishClient.Broker, ackResp.Error) + fmt.Printf("publish2 to %s error: %v\n", publishClient.Broker, ackResp.Error) return } if ackResp.AckSequence > 0 { |