Hi Flink Team, I’m the author of OpenLogReplictor - open source parser of Oracle redo logs which allows to send transactions to some message bus. Currently the sink that is implemented is just text file or Kafka topic. Also transactions can be sent using plain tcp connection or some message queue like ZeroMQ. Code is GPL and all versions from 11.2 are supported. No LogMiner needed.
Transactions can be sent using json or protobuf format. Currently the code has reached GA and is actually used in production. The architecture is modular and allows very easily to add other sinks like for example Apache Flink. Actually I’m going towards approach that OpenLogReplicator could used Kubernetes and work in HA. Well… that is the general direction. Do you think there could some application of this soft with Apache Flink? For example very easily there could be some client which could connect to OpenLogReplicator using tcp connection and get transactions and just send them to Apache Flink. An example of such client is also present in GitHub repo. https://github.com/bersler/OpenLogReplicator Is there any rational for such integration? Or just a waste of time cause nobody would use it anyway? Kind regards, Adam Leszczyński
