Re: Kafka - FLink - MongoDB using Scala

2020-03-29 Thread Konstantin Knauf
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 impl

Re: Kafka + Flink, Basic Questions

2016-10-31 Thread Robert Metzger
Hi Matt, This is a fairly extensive question. I'll try to answer all of them, but I don't have the time right now to extensively discuss the architecture of your application. Maybe there's some other person on the ML who can extend my answers. (Answers in-line below) On Mon, Oct 31, 2016 at 3:37

Re: Kafka+Flink

2016-01-28 Thread Robert Metzger
Hi Vinaya, this blog post explains how to connect Flink and Kafka: http://data-artisans.com/kafka-flink-a-practical-how-to/ On Thu, Jan 28, 2016 at 1:28 AM, Vinaya M S wrote: > Hi, > > I have a 3 node kafka cluster. In server.properties file of each of them > I'm setting > advertisedhost.name: