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 ạ.
1 CÂU TRẢ LỜI
Như này khả năng cao là đang thiếu/sai thư viện debezium trên kafka connect rồi
Kiểm tra lại config path lib của Kafka Connect thêm/ thay thế file jar thư viện debezium restart lại Kafka connect rồi register lại.
Hiện tại em đang chuyển sang sử dụng image của debezium cho kafka connect. Có lẽ image confluent kafka connect cần config khác để có thể implement content based routing