mongo-kafka
                                
                                 mongo-kafka copied to clipboard
                                
                                    mongo-kafka copied to clipboard
                            
                            
                            
                        Support Debezium CDC change stream events
KAFKA-300 Debezium 1.8 support change stream in capture.mode config. The message format for update cdc event is different from oplog mode. Other events are still working with existing code. This PR add new handler class to handle change stream event with full document (debezium capture.mode set to change_streams_update_full).
Thanks @oun for the PR
I'm waiting for this PR to be merged.