[FLINK-5816] I would like to stream data from MongoDB using Flink's source function. Is this possible? Thank you.

• Type: Improvement
• Status: Closed
• Priority: Major
• Resolution: Invalid
• Component/s: API / DataStream
• Labels: mongodb stream

Environment

Flink, MongoDB, Kafka

• Assignee: Unassigned
• Reporter: Pedro Lima Monteiro
• Created: 16/Feb/17 08:58
• Updated: 13/Apr/21 20:31
• Resolved: 16/Feb/17 09:25

Description

I am trying to get data from MongoDB to be analysed in Flink.
I would like to know if it is possible to stream data from MongoDB into Flink. I have looked into Flink's source function to add in the addSource method of the StreamExecutionEnvironment but I had no luck.
Can anyone help me out?
Thanks.