This message was deleted.

pulsar IO is a connector and not a place for stateful traffic to handle CDC stream directly. You should consider debezium as middle layer to handle CDC.