From 971c5d3c6f6bfec5ebf1d103e6d936b19646c347 Mon Sep 17 00:00:00 2001 From: Massimiliano Mirelli Date: Tue, 7 Mar 2023 14:09:34 +0200 Subject: [PATCH] Add sequence tracking number when `seqTracking` is enabled in producer --- .../io/nosqlbench/adapter/pulsar/ops/MessageProducerOp.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/adapter-pulsar/src/main/java/io/nosqlbench/adapter/pulsar/ops/MessageProducerOp.java b/adapter-pulsar/src/main/java/io/nosqlbench/adapter/pulsar/ops/MessageProducerOp.java index f1de93ddf..6f20029bd 100644 --- a/adapter-pulsar/src/main/java/io/nosqlbench/adapter/pulsar/ops/MessageProducerOp.java +++ b/adapter-pulsar/src/main/java/io/nosqlbench/adapter/pulsar/ops/MessageProducerOp.java @@ -135,7 +135,7 @@ public class MessageProducerOp extends PulsarClientOp { } // set message properties - if ( !msgPropRawJsonStr.isEmpty() ) { + if (!StringUtils.isBlank(msgPropRawJsonStr) || seqTracking) { typedMessageBuilder = typedMessageBuilder.properties(msgProperties); }