[pulsar] branch master updated: [improve][c++] Add producerId to the log of closed producer (#17079)

[pe...@apache.org]

This is an automated email from the ASF dual-hosted git repository.

penghui pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/pulsar.git


The following commit(s) were added to refs/heads/master by this push:
     new cbb43d1d4a1 [improve][c++] Add producerId to the log of closed producer (#17079)
cbb43d1d4a1 is described below

commit cbb43d1d4a15a5b5961495cb1248a3b4ac685481
Author: Zike Yang <zi...@apache.org>
AuthorDate: Sun Aug 14 07:24:53 2022 +0800

    [improve][c++] Add producerId to the log of closed producer (#17079)
---
 pulsar-client-cpp/lib/ProducerImpl.cc | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/pulsar-client-cpp/lib/ProducerImpl.cc b/pulsar-client-cpp/lib/ProducerImpl.cc
index 490f381da03..d806bd59f00 100644
--- a/pulsar-client-cpp/lib/ProducerImpl.cc
+++ b/pulsar-client-cpp/lib/ProducerImpl.cc
@@ -694,7 +694,7 @@ void ProducerImpl::closeAsync(CloseCallback callback) {
 void ProducerImpl::handleClose(Result result, ResultCallback callback, ProducerImplPtr producer) {
     if (result == ResultOk) {
         state_ = Closed;
-        LOG_INFO(getName() << "Closed producer");
+        LOG_INFO(getName() << "Closed producer " << producerId_);
         ClientConnectionPtr cnx = getCnx().lock();
         if (cnx) {
             cnx->removeProducer(producerId_);