Cấu hình confluent kafka connect với Debezium ContentBasedRouter

Em chào mọi người. Hiện tại em đang cấu hình kafka connect để replicate database từ postgres sang mongodb. Hiện tại em muốn routing message đến các custom topic dựa trên các database event(insert, update, delete). Config em đang muốn sử dung tích hợp Debezium ContentBasedRouter theo docs Nhưng khi regist sink connector tới kafka connect thì gặp phải lỗi "java.lang.NoClassDefFoundError: io/debezium/DebeziumException". Có anh/chị nào từng cấu hình kafka connect hoặc từng gặp lỗi như vậy giúp em ạ. Em cảm ơn ạ.