From 3bbd3ce6efa9e7c07321d056d7ab31e490e18b9f Mon Sep 17 00:00:00 2001 From: Evan Savage Date: Wed, 21 May 2025 18:55:28 +0200 Subject: [PATCH] call correct function to set subscription role prefix --- src/ReaderConfig.cc | 3 ++- 1 file changed, 2 insertions(+), 1 deletion(-) diff --git a/src/ReaderConfig.cc b/src/ReaderConfig.cc index 1e56063e..539da07f 100644 --- a/src/ReaderConfig.cc +++ b/src/ReaderConfig.cc @@ -72,7 +72,8 @@ ReaderConfig::ReaderConfig(const Napi::Object &readerConfig, pulsar_reader_liste 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()); + pulsar_reader_configuration_set_subscription_role_prefix(this->cReaderConfig.get(), + subscriptionRolePrefix.c_str()); } if (readerConfig.Has(CFG_READ_COMPACTED) && readerConfig.Get(CFG_READ_COMPACTED).IsBoolean()) {