paladin-dalao commented on issue #13267:
URL: https://github.com/apache/pulsar/issues/13267#issuecomment-993218032
> What's your C++ client version? I see
>
> ```
> ==00:00:41:04.793 10873== by 0xCDB4B1:
thread<std::_Bind<std::_Mem_fn<void
(pulsar::ExecutorService::*)(std::shared_ptr<boost::asio::io_service>)>(pulsar::ExecutorService*,
std::shared_ptr<boost::asio::io_service>)> > (thread:135)
> ==00:00:41:04.793 10873== by 0xCDB4B1:
pulsar::ExecutorService::ExecutorService() (ExecutorService.cc:30)
> ```
>
> The constructor of `ExecutorService` starts a thread. However, some
refactors have been introduced after #12427, please check again with latest
master.
>
> BTW, could you upload a (minimum) whole code file and the valgrind command
so that I can try to reproduce it in my local env?
1 . gcc version 4.8.5 20150623 (Red Hat 4.8.5-16) (GCC)
2. Test like this, create producer failed
```
#include <pulsar/c/client.h>
#include <stdio.h>
#include <string.h>
int main() {
pulsar_client_configuration_t *conf =
pulsar_client_configuration_create();
pulsar_client_t *client =
pulsar_client_create("pulsar://localhost:6650", conf);
pulsar_producer_configuration_t* producer_conf =
pulsar_producer_configuration_create();
pulsar_producer_configuration_set_batching_enabled(producer_conf, 1);
pulsar_producer_t *producer;
for (int i = 0; i < 1000; i++) {
pulsar_result err = pulsar_client_create_producer(client,
"my-topic", producer_conf, &producer);
if (err != pulsar_result_Ok) {
printf("Failed to create producer: %s\n",
pulsar_result_str(err));
pulsar_producer_configuration_free(producer_conf);
continue;
}
pulsar_producer_close(producer);
pulsar_producer_free(producer);
pulsar_producer_configuration_free(producer_conf);
}
pulsar_client_close(client);
pulsar_client_free(client);
pulsar_client_configuration_free(conf);
}
```
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
