Debezium Content Based Routing

[Joseph Aliase]

Thanks in advance for the help.

I'm hitting a very odd issue with ContentBasedRouter. My expression works correctly for create and update operations but not for delete operations. All delete operations are sent to the default topic. Even if I keep the expression as simple as below, the events are forwarded to the stream-topic topic for create and update but not for delete. What am I missing?

"transforms": "route",
"transforms.route": "io.debezium.transforms.ContentBasedRouter",
"transforms.route": "jsr223.groovy",
"transforms.route.topic.expression": "'stream-topic'"