The use of non-persistent topics isn’t necessary in this scenario, as the consumers will be getting the data directly from the broker cache. You could adjust the write and ack quorums to 1 and 0, respectively, instead.

Thank you @David K you have always come through, one last question about this please. The flags you have mentioned, for pulsar sink connector, it has to be set in

inputSpecs[<topicName>][consumerPoroperties]

"inputSpecs": {
"topicName": {
"schemaProperties": {},
"consumerProperties": {
"subscriptionType": "Exclusive",
},
"receiverQueueSize": 0,
"poolMessages": true,
"regexPattern": false
}
},

right ?

inputSpecs is a map of (topic name, ConsumerConfig)

@David K thanks always