Hi Mohan,
I don't know the specifics about the single Kafka Connect worker.
The Flink CDC connector is NOT a Kafka Connector. As explained before,
there is no Kafka involved when using this connector. As also is mentioned
in the same readme, it indeed provides exactly once processing.
Best regar
Hello,
Ok. I may not have understood the answer to my previous
question.
When I listen to https://www.youtube.com/watch?v=IOZ2Um6e430 at 20:14 he
starts to talk about this.
Is he talking about a single Kafka Connect worker or a cluster ? He
mentions that it is 'atleast-once'.
So Flink
Hi,
The readme on the Flink CDC connectors [1] say that Oracle Databases
version 11, 12, 19 are supported with Oracle Driver 19.3.0.0.
Best regards,
Martijn
[1] https://github.com/ververica/flink-cdc-connectors/blob/master/README.md
On Fri, 11 Feb 2022 at 08:37, mohan radhakrishnan <
radhakris
Thanks. I looked at it. Our primary DB is Oracle and MySql. Flink CDC
Connector uses Debezium. I think. So ververica doesn't have a Flink CDC
Connector for Oracle ?
On Mon, Feb 7, 2022 at 3:03 PM Leonard Xu wrote:
> Hello, mohan
>
> 1. Does flink have any support to track any missed source Jdbc
Hello, mohan
> 1. Does flink have any support to track any missed source Jdbc CDC records ?
Flink CDC Connector provides Exactly once semantics which means they won’t miss
records. Tips: The Flink JDBC Connector only
Scan the database once which can not continuously read CDC stream.
> 2. What
Hello,
I have some specific questions. Appreciate some pointers
1. Does flink have any support to track any missed source Jdbc CDC records
?
2. What is the equivalent of Kafka consumer groups ?
3. Delivering to kafka from flink is not exactly once. Is that right ?
Thanks
On Friday, F
Hello,
So the jdbc source connector is kafka and transformation is
done by flink (flink sql) ? But that connector can miss records. I thought.
Started looking at flink for this and other use cases.
Can I see the alternative to spring cloudstreams( kafka streams )? Since I
am learnin
Hi Mohan,
I don't know much about Kafka Connect, so I will not talk about its
features and differences to Flink. Flink on its own does not have a
capability to read a CDC stream directly from a DB. However there is the
flink-cdc-connectors[1] projects which embeds the standalone Debezium
engi
Hi,
When I was looking for CDC I realized Flink uses Kafka Connector to
stream to Flink. The idea is to send it forward to Kafka and consume it
using Kafka Streams.
Are there source DLQs or additional mechanisms to detect failures to read
from the DB ?
We don't want to use Debezium and our C
