Re: [I] [Bug] [Sink] mongodb change stream sink into kafka format error [seatunnel]

2025-03-12 Thread via GitHub
github-actions[bot] commented on issue #8619: URL: https://github.com/apache/seatunnel/issues/8619#issuecomment-2719440477 This issue has been automatically marked as stale because it has not had recent activity for 30 days. It will be closed in next 7 days if no further activity occurs.

Re: [I] [Bug] [Sink] mongodb change stream sink into kafka format error [seatunnel]

2025-02-08 Thread via GitHub
KRISHNA-798 commented on issue #8619: URL: https://github.com/apache/seatunnel/issues/8619#issuecomment-2645011156 Hi @SoulSong , yes you are right but mongodb cdc works with "debezium_json" format in kafka source and sink. 1st config: ``` env { parallelism = 1 job

Re: [I] [Bug] [Sink] mongodb change stream sink into kafka format error [seatunnel]

2025-02-07 Thread via GitHub
SoulSong commented on issue #8619: URL: https://github.com/apache/seatunnel/issues/8619#issuecomment-2642375696 > Hi [@SoulSong](https://github.com/SoulSong) > > > Expect output message format as change stream realtime origin format. > > Can you explain what's format do you want

Re: [I] [Bug] [Sink] mongodb change stream sink into kafka format error [seatunnel]

2025-02-06 Thread via GitHub
liunaijie commented on issue #8619: URL: https://github.com/apache/seatunnel/issues/8619#issuecomment-2641569874 Hi @SoulSong > Expect output message format as change stream realtime origin format. Can you explain what's format do you want. SeaTunnel can also support debezium form