Bump cpp version to 4.1.0 (#471)

Author: shibd

index.d.ts

@@ -25,7 +25,6 @@ export interface ClientConfig {
   ioThreads?: number;
   messageListenerThreads?: number;
   concurrentLookupRequest?: number;
-  useTls?: boolean;
   tlsTrustCertsFilePath?: string;
   tlsCertificateFilePath?: string;
   tlsPrivateKeyFilePath?: string;

pulsar-client-cpp.txt

@@ -1,2 +1,2 @@
-CPP_CLIENT_BASE_URL=https://archive.apache.org/dist/pulsar/pulsar-client-cpp-4.0.1
-CPP_CLIENT_VERSION=4.0.1
+CPP_CLIENT_BASE_URL=https://archive.apache.org/dist/pulsar/pulsar-client-cpp-4.1.0
+CPP_CLIENT_VERSION=4.1.0

src/Client.cc

@@ -35,7 +35,6 @@ static const std::string CFG_OP_TIMEOUT = "operationTimeoutSeconds";
 static const std::string CFG_IO_THREADS = "ioThreads";
 static const std::string CFG_LISTENER_THREADS = "messageListenerThreads";
 static const std::string CFG_CONCURRENT_LOOKUP = "concurrentLookupRequest";
-static const std::string CFG_USE_TLS = "useTls";
 static const std::string CFG_TLS_TRUST_CERT = "tlsTrustCertsFilePath";
 static const std::string CFG_TLS_VALIDATE_HOSTNAME = "tlsValidateHostname";
 static const std::string CFG_TLS_ALLOW_INSECURE = "tlsAllowInsecureConnection";
@@ -187,11 +186,6 @@ Client::Client(const Napi::CallbackInfo &info) : Napi::ObjectWrap<Client>(info)
     }
   }
 
-  if (clientConfig.Has(CFG_USE_TLS) && clientConfig.Get(CFG_USE_TLS).IsBoolean()) {
-    Napi::Boolean useTls = clientConfig.Get(CFG_USE_TLS).ToBoolean();
-    pulsar_client_configuration_set_use_tls(cClientConfig.get(), useTls.Value());
-  }
-
   if (clientConfig.Has(CFG_TLS_TRUST_CERT) && clientConfig.Get(CFG_TLS_TRUST_CERT).IsString()) {
     Napi::String tlsTrustCertsFilePath = clientConfig.Get(CFG_TLS_TRUST_CERT).ToString();
     pulsar_client_configuration_set_tls_trust_certs_file_path(cClientConfig.get(),

tests/end_to_end.test.js

@@ -1409,14 +1409,15 @@ const Pulsar = require('../index');
         });
       }
 
-      // 2. Verify message order (based on key dictionary order)
+      // 2. Verify message order follows the first sequence id per key-based batch,
+      // matching pulsar-client-cpp#546.
       const expected = [
+        { key: 'A', value: '0' },
+        { key: 'A', value: '5' },
         { key: 'B', value: '1' },
         { key: 'B', value: '3' },
         { key: 'C', value: '2' },
         { key: 'C', value: '4' },
-        { key: 'A', value: '0' },
-        { key: 'A', value: '5' },
       ];
 
       expect(received).toEqual(expected);
@@ -1438,17 +1439,18 @@ const Pulsar = require('../index');
 
       // 2. Receive messages and verify their order and keys
       const msg1 = await receiveAndAck();
-      expect(msg1.getData().toString()).toBe('2');
-      expect(msg1.getOrderingKey().toString()).toBe('B');
+      expect(msg1.getData().toString()).toBe('0');
+      expect(msg1.getOrderingKey().toString()).toBe('A');
+      expect(msg1.getPartitionKey()).toBe('B');
 
       const msg2 = await receiveAndAck();
-      expect(msg2.getData().toString()).toBe('0');
-      expect(msg2.getOrderingKey()).toBe('A');
-      expect(msg2.getPartitionKey()).toBe('B');
+      expect(msg2.getData().toString()).toBe('1');
+      expect(msg2.getOrderingKey().toString()).toBe('A');
+      expect(msg2.getPartitionKey()).toBe('');
 
       const msg3 = await receiveAndAck();
-      expect(msg3.getData().toString()).toBe('1');
-      expect(msg3.getOrderingKey().toString()).toBe('A');
+      expect(msg3.getData().toString()).toBe('2');
+      expect(msg3.getOrderingKey().toString()).toBe('B');
     });
   });
 })();

tstest.ts

@@ -84,7 +84,6 @@ import Pulsar = require('./index');
     ioThreads: 4,
     messageListenerThreads: 4,
     concurrentLookupRequest: 100,
-    useTls: false,
     tlsTrustCertsFilePath: '/path/to/ca-cert.pem',
     tlsValidateHostname: false,
     tlsAllowInsecureConnection: false,