kafka-tutorials

kafka-tutorials copied to clipboard

I think the credit card fraud recipe would benefit from having an example source connector. Our technical marketing demo for database modernization does this with Oracle CDC:

• https://github.com/confluentinc/demo-database-modernization/blob/master/confluent/example_oracle_cdc.json

There is a small issue when doing this -- you will get a "column name already exists" when creating the customers table because the connector will set a json record key called id. So you would have to rename the field and do something like this:

CREATE TABLE FD_CUSTOMERS (
  customer_id DOUBLE PRIMARY KEY
  ) WITH (KAFKA_TOPIC = 'ORCL.ADMIN.CUSTOMERS',KEY_FORMAT='JSON',VALUE_FORMAT = 'JSON_SR');

All subsequent references to the field would have to be updated too.

For more information, see

• https://github.com/confluentinc/demo-database-modernization/issues/5