[pulsar-client-node] branch master updated: Respect maxPendingMessagesAcrossPartitions (#231)

[mmerli]

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

mmerli pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/pulsar-client-node.git


The following commit(s) were added to refs/heads/master by this push:
     new ca54275  Respect maxPendingMessagesAcrossPartitions (#231)
ca54275 is described below

commit ca54275634fc00af14a677e0a491fbc1158d7e9a
Author: Robert Kawecki <rka...@users.noreply.github.com>
AuthorDate: Sat Sep 17 19:23:09 2022 +0200

    Respect maxPendingMessagesAcrossPartitions (#231)
    
    Fixes #230
    
    This change should help avoid `ProducerQueueIsFull` errors when producing 
to a partitioned topic with batchingEnabled.
---
 src/ProducerConfig.cc | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/src/ProducerConfig.cc b/src/ProducerConfig.cc
index 289c55f..2be94df 100644
--- a/src/ProducerConfig.cc
+++ b/src/ProducerConfig.cc
@@ -100,7 +100,7 @@ ProducerConfig::ProducerConfig(const Napi::Object& 
producerConfig) : topic("") {
     int32_t maxPendingMessagesAcrossPartitions =
         
producerConfig.Get(CFG_MAX_PENDING_ACROSS_PARTITIONS).ToNumber().Int32Value();
     if (maxPendingMessagesAcrossPartitions > 0) {
-      
pulsar_producer_configuration_set_max_pending_messages(this->cProducerConfig.get(),
+      
pulsar_producer_configuration_set_max_pending_messages_across_partitions(this->cProducerConfig.get(),
                                                              
maxPendingMessagesAcrossPartitions);
     }
   }