[][src]Function pulsar_sys::pulsar_message_set_replication_clusters

pub unsafe extern "C" fn pulsar_message_set_replication_clusters(
    message: *mut pulsar_message_t,
    clusters: *mut *const c_char,
    size: size_t
)

override namespace replication clusters. note that it is the caller's responsibility to provide valid cluster names, and that all clusters have been previously configured as topics.

given an empty list, the message will replicate per the namespace configuration.

@param clusters where to send this message.