From ac2fdf2a2e674525c1ea67e9b75c785ae5088786 Mon Sep 17 00:00:00 2001 From: Yabin Meng Date: Wed, 13 Oct 2021 10:11:20 -0500 Subject: [PATCH] Convert message error runtime exception to counter metrics --- .../resources/activities/pulsar_client_sanity_seqloss.yaml | 3 ++- 1 file changed, 2 insertions(+), 1 deletion(-) diff --git a/driver-pulsar/src/main/resources/activities/pulsar_client_sanity_seqloss.yaml b/driver-pulsar/src/main/resources/activities/pulsar_client_sanity_seqloss.yaml index 49a139f05..61f3258b4 100644 --- a/driver-pulsar/src/main/resources/activities/pulsar_client_sanity_seqloss.yaml +++ b/driver-pulsar/src/main/resources/activities/pulsar_client_sanity_seqloss.yaml @@ -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}"