candu opened a new issue, #415:
URL: https://github.com/apache/pulsar-client-node/issues/415

   In the following section of `src/ReaderConfig.cc`:
   
   ```cpp
   if (readerConfig.Has(CFG_SUBSCRIPTION_ROLE_PREFIX) &&
         readerConfig.Get(CFG_SUBSCRIPTION_ROLE_PREFIX).IsString()) {
       std::string subscriptionRolePrefix =
           
readerConfig.Get(CFG_SUBSCRIPTION_ROLE_PREFIX).ToString().Utf8Value();
       if (!subscriptionRolePrefix.empty())
         pulsar_reader_configuration_set_reader_name(this->cReaderConfig.get(), 
subscriptionRolePrefix.c_str());
     }
   ```
   
   it should call `pulsar_reader_configuration_set_subscription_role_prefix` 
instead of `pulsar_reader_configuration_set_reader_name`.
   
   This bug results in warnings such as:
   
   ```
   [17:03:34.537] WARN (app logger/21232 on M-01390): Pulsar warning: 
[192.168.0.124:50068 -> 54.75.236.18:6651] Received error response from server: 
AuthorizationError (org.apache.pulsar.broker.PulsarServerException: Failed to 
create consumer - The subscription name needs to be prefixed by the 
authentication role, like 99b03f54-91fd-41c0-8e8f-0c43006cbe8c-xxxx for topic: 
persistent://prod/LEGO.ProductDevelopment.ProductDiscovery/products-b778c389-eba6-43f3-b665-433839b40194-v1)
 -- req_id: 0
   ```
   
   which, depending on the Pulsar cluster setup, can result in unexpected 
behaviour or authorization errors.


-- 
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: commits-unsubscr...@pulsar.apache.org.apache.org

For queries about this service, please contact Infrastructure at:
us...@infra.apache.org

Reply via email to