IntenseFinance/nosqlbench
3
0
Fork 0
mirror of https://github.com/nosqlbench/nosqlbench.git synced 2025-01-11 00:12:04 -06:00
Code Issues Packages Projects Releases Wiki Activity

Add sequence tracking number when seqTracking is enabled in producer

Browse Source
This commit is contained in:
Massimiliano Mirelli 2023-03-07 14:09:34 +02:00
parent b333898249
commit 971c5d3c6f
1 changed files with 1 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
adapter-pulsar/src/main/java/io/nosqlbench/adapter/pulsar/ops/MessageProducerOp.java
View File

@ -135,7 +135,7 @@ public class MessageProducerOp extends PulsarClientOp {
}
// set message properties
if ( !msgPropRawJsonStr.isEmpty() ) {
if (!StringUtils.isBlank(msgPropRawJsonStr) || seqTracking) {
typedMessageBuilder = typedMessageBuilder.properties(msgProperties);
}