Convert message error runtime exception to counter metrics

This commit is contained in:
Yabin Meng 2021-10-13 10:11:20 -05:00
parent 686af3d9ca
commit ac2fdf2a2e

View File

@ -5,7 +5,7 @@ bindings:
# document level parameters that apply to all Pulsar client types:
params:
topic_uri: "persistent://public/default/sanity_seqloss2"
topic_uri: "persistent://tnt0/ns0/sanity_seqloss12"
# Only applicable to producer and consumer
# - used for message ordering and message loss check
async_api: "true"
@ -23,6 +23,7 @@ blocks:
#seqerr_simu: "out_of_order"
#seqerr_simu: "msg_loss"
#seqerr_simu: "msg_dup"
seqerr_simu: "out_of_order, msg_loss"
msg_key:
msg_property:
msg_value: "{myvalue}"