diff --git a/src/ConsumerConfig.cc b/src/ConsumerConfig.cc index 47f25cea..ac301c5e 100644 --- a/src/ConsumerConfig.cc +++ b/src/ConsumerConfig.cc @@ -291,7 +291,7 @@ void ConsumerConfig::InitConfig(const std::shared_ptr deferr } pulsar_consumer_configuration_set_dlq_policy(this->cConsumerConfig.get(), &dlq_policy); } - + if (consumerConfig.Has(CFG_BATCH_RECEIVE_POLICY) && consumerConfig.Get(CFG_BATCH_RECEIVE_POLICY).IsObject()) { Napi::Object propObj = consumerConfig.Get(CFG_BATCH_RECEIVE_POLICY).ToObject();