cc user@f.a.o
Hi Siva,
I am not aware of a Flink MongoDB Connector in either Apache Flink, Apache
Bahir or flink-packages.org. I assume that you are doing idempotent
upserts, and hence do not require a transactional sink to achieve
end-to-end exactly-once results.
To build one yourself, you
Hi
I'm working on creating a streaming pipeline which streams data from Kafka
and stores in MongoDB using Flink scala.
I'm able to successfully stream data from Kafka using FLink Scala. I'm not
finding any support to store the data into MongoDB, could you please help
me with the code snippet to
