Is it possible to use oracle Connector with DebeziumIO. I see in the KafkaConsumerFn, in the process method everytime we are creating jdbc connection. Will this work in high throughput envionment. DebeziumIO is still in expermental mode, when will it be moved to stable project
Asked
Active
Viewed 83 times
1 Answers
0
A better place to create jdbc connections is under setup or start_bundle instead of in process, more details see: What is the difference between DoFn.Setup and DoFn.StartBundle?.
About DebeziumIO, since Apache Beam is an OSS project, so maybe try contacting the main contributors to this I/O.
ningk
- 1,298
- 1
- 7
- 7