46 lines
1.9 KiB
Plaintext
46 lines
1.9 KiB
Plaintext
// Metadata created by nebel
|
|
//
|
|
// UserStory: As an evaluator, I want to use Debezium to view create, update, and delete events in my database.
|
|
|
|
:context: debezium
|
|
|
|
[id="viewing-change-events"]
|
|
= Viewing change events
|
|
|
|
After deploying the {prodname} MySQL connector,
|
|
it starts monitoring the `inventory` database for data change events.
|
|
|
|
When you watched the connector start up,
|
|
you saw that events were written to the following topics with the `dbserver1` prefix (the name of the connector):
|
|
|
|
`dbserver1`::
|
|
The xref:connectors/mysql.adoc#schema-change-topic[schema change topic] to which all of the DDL statements are written.
|
|
|
|
`dbserver1.inventory.products`::
|
|
Captures change events for the `products` table in the `inventory` database.
|
|
|
|
`dbserver1.inventory.products_on_hand`::
|
|
Captures change events for the `products_on_hand` table in the `inventory` database.
|
|
|
|
`dbserver1.inventory.customers`::
|
|
Captures change events for the `customers` table in the `inventory` database.
|
|
|
|
`dbserver1.inventory.orders`::
|
|
Captures change events for the `orders` table in the `inventory` database.
|
|
|
|
For this tutorial, you will explore the `dbserver1.inventory.customers` topic.
|
|
In this topic, you will see different types of change events to see how the connector captured them:
|
|
|
|
* xref:viewing-create-event[Viewing a _create_ event]
|
|
* xref:updating-database-viewing-update-event[Updating the database and viewing the _update_ event]
|
|
* xref:deleting-record-database-viewing-delete-event[Deleting a record in the database and viewing the _delete_ event]
|
|
* xref:restarting-kafka-connect-service[Restarting Kafka Connect and changing the database]
|
|
|
|
include::../../modules/tutorial/p_viewing-create-event.adoc[leveloffset=+1]
|
|
|
|
include::../../modules/tutorial/p_updating-database-viewing-update-event.adoc[leveloffset=+1]
|
|
|
|
include::../../modules/tutorial/p_deleting-record-database-viewing-delete-event.adoc[leveloffset=+1]
|
|
|
|
include::../../modules/tutorial/p_restarting-kafka-connect-service.adoc[leveloffset=+1]
|