From 06672c7db7fb221128cd615ec671297acd7bb56a Mon Sep 17 00:00:00 2001
From: Samith Karunathilake <samithkarunathilake@gmail.com>
Date: Wed, 9 Jul 2025 14:29:11 +0530
Subject: [PATCH 1/2] Update documentation

---
 README.md           | 20 +++++++++++---------
 ballerina/README.md | 20 +++++++++++---------
 2 files changed, 22 insertions(+), 18 deletions(-)

diff --git a/README.md b/README.md
index b6956a9..26e2276 100644
--- a/README.md
+++ b/README.md
@@ -37,11 +37,13 @@ Create a CDC listener for your MySQL database by specifying the connection detai
 
 ```ballerina
 listener mysql:CdcListener mysqlListener = new ({
-    hostname: "localhost",
-    port: 3306,
-    username: "username",
-    password: "password",
-    databaseInclude: ["inventory"]
+    database: {
+        hostname: "localhost",
+        port: 3306,
+        username: "username",
+        password: "password",
+        includedDatabases: ["inventory"]
+    }
 });
 ```
 
@@ -52,22 +54,22 @@ Implement a `cdc:Service` to handle database change events:
 ```ballerina
 service on mysqlListener {
 
-    remote function onRead(record {} after) returns error? {
+    remote function onRead(record {} after) returns cdc:Error? {
         // Handle the read event
         log:printInfo(`Record read: ${after}`);
     }
 
-    remote function onCreate(record {} after) returns error? {
+    remote function onCreate(record {} after) returns cdc:Error? {
         // Handle the create event
         log:printInfo(`Record created: ${after}`);
     }
 
-    remote function onUpdate(record {} before, record {} after) returns error? {
+    remote function onUpdate(record {} before, record {} after) returns cdc:Error? {
         // Handle the update event
         log:printInfo(`Record updated from: ${before}, to ${after}`);
     }
 
-    remote function onDelete(record {} before) returns error? {
+    remote function onDelete(record {} before) returns cdc:Error? {
         // Handle the delete event
         log:printInfo(`Record deleted: ${before}`);
     }
diff --git a/ballerina/README.md b/ballerina/README.md
index a303781..f3e67b7 100644
--- a/ballerina/README.md
+++ b/ballerina/README.md
@@ -29,11 +29,13 @@ Create a CDC listener for your MySQL database by specifying the connection detai
 
 ```ballerina
 listener mysql:CdcListener mysqlListener = new ({
-    hostname: "localhost",
-    port: 3306,
-    username: "username",
-    password: "password",
-    databaseInclude: ["inventory"]
+    database: {
+        hostname: "localhost",
+        port: 3306,
+        username: "username",
+        password: "password",
+        includedDatabases: ["inventory"]
+    }
 });
 ```
 
@@ -44,22 +46,22 @@ Implement a `cdc:Service` to handle database change events:
 ```ballerina
 service on mysqlListener {
 
-    remote function onRead(record {} after) returns error? {
+    remote function onRead(record {} after) returns cdc:Error? {
         // Handle the read event
         log:printInfo(`Record read: ${after}`);
     }
 
-    remote function onCreate(record {} after) returns error? {
+    remote function onCreate(record {} after) returns cdc:Error? {
         // Handle the create event
         log:printInfo(`Record created: ${after}`);
     }
 
-    remote function onUpdate(record {} before, record {} after) returns error? {
+    remote function onUpdate(record {} before, record {} after) returns cdc:Error? {
         // Handle the update event
         log:printInfo(`Record updated from: ${before}, to ${after}`);
     }
 
-    remote function onDelete(record {} before) returns error? {
+    remote function onDelete(record {} before) returns cdc:Error? {
         // Handle the delete event
         log:printInfo(`Record deleted: ${before}`);
     }

From ca5fb7b7b6eda5ddec98798e9c2e3e688adda71f Mon Sep 17 00:00:00 2001
From: Niveathika <niveathika@wso2.com>
Date: Wed, 9 Jul 2025 20:47:37 +0530
Subject: [PATCH 2/2] Update changelog.md

---
 changelog.md | 5 +++++
 1 file changed, 5 insertions(+)

diff --git a/changelog.md b/changelog.md
index 376bdfc..d6d72bb 100644
--- a/changelog.md
+++ b/changelog.md
@@ -9,6 +9,11 @@ and this project adheres to [Semantic Versioning](https://semver.org/spec/v2.0.0
 
 ### Added
 
+### Changed
+- Fix documentation
+
+## [1.0.3] - 2025-05-29
+
 ### Changed
 - Fixed schema not included in service map key
 - Fix data binding error being invoked incorrectly