|
@ -166,12 +166,12 @@ func (p *TopicPublisher) doPublishToPartition(job *EachPartitionPublishJob) erro |
|
|
return |
|
|
return |
|
|
} |
|
|
} |
|
|
publishClient.Err = err |
|
|
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 |
|
|
return |
|
|
} |
|
|
} |
|
|
if ackResp.Error != "" { |
|
|
if ackResp.Error != "" { |
|
|
publishClient.Err = fmt.Errorf("ack error: %v", 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 |
|
|
return |
|
|
} |
|
|
} |
|
|
if ackResp.AckSequence > 0 { |
|
|
if ackResp.AckSequence > 0 { |
|
|