Consume Pulsar CDC events in AsyncService

[longquanzheng]

Test passed with message consumed:

waiting for messages
{"level":"info","ts":"2023-09-29T14:38:15.230-0700","msg":"test, test received value","ID":"35:3:0","Key":"eyJpZCI6Ik4yVmpORFk1WW1NdE5XWXhNQzB4TVdWbExUazVZMkl0TldGaVpXUmlaams1TnpkaiJ9","value":"{\"before\":null,\"after\":{\"id\":\"N2VjNDY5YmMtNWYxMC0xMWVlLTk5Y2ItNWFiZWRiZjk5Nzdj\",\"process_id\":\"TestProceedOnStateStartFailWorkflow1696023494\",\"is_current\":true,\"status\":\"running\",\"start_time\":1695998294615080,\"timeout_seconds\":0,\"history_event_id_sequence\":0,\"info\":\"{\\\"workerURL\\\": \\\"http://localhost:8803\\\", \\\"processType\\\": \\\"basic.IOProcess\\\"}\"},\"source\":{\"version\":\"1.9.7.Final\",\"connector\":\"postgresql\",\"name\":\"dbserver1\",\"ts_ms\":1696023494619,\"snapshot\":\"false\",\"db\":\"xdb\",\"sequence\":\"[\\\"37842576\\\",\\\"38039656\\\"]\",\"schema\":\"public\",\"table\":\"xdb_sys_process_executions\",\"txId\":798,\"lsn\":38039656,\"xmin\":null},\"op\":\"c\",\"ts_ms\":1696023494773,\"transaction\":null}","logging-call-at":"process_mq_pulsar_impl.go:67"}
--- PASS: TestStartBasicProcessPostgres (10.05s)

[codecov[bot]]

Codecov Report

All modified lines are covered by tests :white_check_mark:

Comparison is base (ace1e12) 66.66% compared to head (b160bf5) 66.66%.

Additional details and impacted files

```diff @@ Coverage Diff @@ ## main #26 +/- ## ======================================= Coverage 66.66% 66.66% ======================================= Files 1 1 Lines 6 6 ======================================= Hits 4 4 Misses 1 1 Partials 1 1 ```

:umbrella: View full report in Codecov by Sentry.
:loudspeaker: Have feedback on the report? Share it here.