fix pulsar_message_set_replication_clusters (#3729)

pulsar-client-cpp/include/pulsar/c/message.h

@@ -87,7 +87,7 @@ void pulsar_message_set_sequence_id(pulsar_message_t *message, int64_t sequenceI
  *
  * @param clusters where to send this message.
  */
-void pulsar_message_set_replication_clusters(pulsar_message_t *message, const char **clusters);
+void pulsar_message_set_replication_clusters(pulsar_message_t *message, const char **clusters, size_t size);
 
 /**
  * Do not replicate this message
@@ -173,4 +173,4 @@ const char *pulsar_message_get_topic_name(pulsar_message_t *message);
 
 #ifdef __cplusplus
 }
-#endif
\ No newline at end of file
+#endif

pulsar-client-cpp/lib/c/c_Message.cc

@@ -48,11 +48,11 @@ void pulsar_message_set_sequence_id(pulsar_message_t *message, int64_t sequenceI
     message->builder.setSequenceId(sequenceId);
 }
 
-void pulsar_message_set_replication_clusters(pulsar_message_t *message, const char **clusters) {
-    const char *c = clusters[0];
+void pulsar_message_set_replication_clusters(pulsar_message_t *message, const char **clusters, size_t size) {
+    const char **c = clusters;
     std::vector<std::string> clustersList;
-    while (c) {
-        clustersList.push_back(c);
+    for (size_t i = 0; i < size; i++) {
+        clustersList.push_back(*c);
         ++c;
     }
 

pulsar-client-go/pulsar/c_message.go

@@ -88,7 +88,7 @@ func buildMessage(message ProducerMessage) *C.pulsar_message_t {
 				C.setString(array, C.CString(s), C.int(i))
 			}
 
-			C.pulsar_message_set_replication_clusters(cMsg, array)
+			C.pulsar_message_set_replication_clusters(cMsg, array, size)
 		}
 	}