apache kafka – Capture Oracle metadata via Debezium connector
I’m sourcing Oracle data into Kafka topics using Debezium Oracle connector.
I have a source Oracle table, as below:
CREATE TABLE MYDATA.MY_USER
(
USER_ID RAW(16) DEFAULT SYS_GUID() NOT NULL,
FIRST_NAME VARCHAR2(100) NOT NULL,
...
CONSTRAINT "PK_MY_USER" PRIMARY KEY (USER_ID)
);
COMMENT ON TABLE MYDATA.MY_USER '{"tags.category": "Personal", "description": "User master data."}';
COMMENT ON COLUMN MYDATA.MY_USER.DOB IS '{"tags.category": "PII", "description": "User date of birth."}';
Now, I’d like these metadata values (COMMENT ON properties) to be carried over by Debezium along with Change Data Capture, so that I can access data as well as metadata from the Kafka topic. Can you help me achieve this? Do you know the Debezium connector properties that can help achieve this?
Ref: debezium.io/documentation/reference/stable/connectors/oracle.html
Read more here: Source link
