Skip to content

Conversation

@subkanthi
Copy link
Collaborator

closes: #1198

@subkanthi
Copy link
Collaborator Author

ctor-lt-1  | 2025-11-26 01:09:46.761 INFO  - ****** Thread: Sink connector Debezium Event Thread Batch Size: 2048 ******
clickhouse-sink-connector-lt-1  | 2025-11-26 01:09:46.779 INFO  - *** INSERT QUERY for Database(sbtest) ***: insert into `sbtest1`(`id`,`k`,`c`,`pad`,`_version`,`is_deleted`) select `id`,`k`,`c`,`pad`,`_version`,`is_deleted` from input('`id` Int32,`k` Int32,`c` String,`pad` String,`_version` UInt64,`is_deleted` UInt8')
clickhouse-sink-connector-lt-1  | 2025-11-26 01:09:46.879 INFO  - *************** EXECUTED BATCH Successfully Records: 2048************** task(0) Thread ID: Sink connector Debezium Event Thread Result: [I@25c99870 Database: sbtest Table: sbtest1
clickhouse-sink-connector-lt-1  | 2025-11-26 01:09:46.879 INFO  - ****** Acknowledging records ******
clickhouse-sink-connector-lt-1  | 2025-11-26 01:09:46.915 INFO  - ****** Thread: Sink connector Debezium Event Thread Batch Size: 2048 ******
clickhouse-sink-connector-lt-1  | 2025-11-26 01:09:46.928 INFO  - *** INSERT QUERY for Database(sbtest) ***: insert into `sbtest1`(`id`,`k`,`c`,`pad`,`_version`,`is_deleted`) select `id`,`k`,`c`,`pad`,`_version`,`is_deleted` from input('`id` Int32,`k` Int32,`c` String,`pad` String,`_version` UInt64,`is_deleted` UInt8')
clickhouse-sink-connector-lt-1  | 2025-11-26 01:09:47.018 INFO  - *************** EXECUTED BATCH Successfully Records: 2048************** task(0) Thread ID: Sink connector Debezium Event Thread Result: [I@e66feb2 Database: sbtest Table: sbtest1
clickhouse-sink-connector-lt-1  | 2025-11-26 01:09:47.018 INFO  - ****** Acknowledging records ******
clickhouse-sink-connector-lt-1  | 2025-11-26 01:09:47.059 INFO  - ****** Thread: Sink connector Debezium Event Thread Batch Size: 2048 ******
clickhouse-sink-connector-lt-1  | 2025-11-26 01:09:47.067 INFO  - *** INSERT QUERY for Database(sbtest) ***: insert into `sbtest1`(`id`,`k`,`c`,`pad`,`_version`,`is_deleted`) select `id`,`k`,`c`,`pad`,`_version`,`is_deleted` from input('`id` Int32,`k` Int32,`c` String,`pad` String,`_version` UInt64,`is_deleted` UInt8')
clickhouse-sink-connector-lt-1  | 2025-11-26 01:09:47.132 INFO  - *************** EXECUTED BATCH Successfully Records: 2048************** task(0) Thread ID: Sink connector Debezium Event Thread Result: [I@6065f4bb Database: sbtest Table: sbtest1
clickhouse-sink-connector-lt-1  | 2025-11-26 01:09:47.133 INFO  - ****** Acknowledging records ******
clickhouse-sink-connector-lt-1  | 2025-11-26 01:09:47.157 INFO  - ****** Thread: Sink connector Debezium Event Thread Batch Size: 2048 ******
clickhouse-sink-connector-lt-1  | 2025-11-26 01:09:47.164 INFO  - *** INSERT QUERY for Database(sbtest) ***: insert into `sbtest1`(`id`,`k`,`c`,`pad`,`_version`,`is_deleted`) select `id`,`k`,`c`,`pad`,`_version`,`is_deleted` from input('`id` Int32,`k` Int32,`c` String,`pad` String,`_version` UInt64,`is_deleted` UInt8')
clickhouse-sink-connector-lt-1  | 2025-11-26 01:09:47.225 INFO  - *************** EXECUTED BATCH Successfully Records: 2048************** task(0) Thread ID: Sink connector Debezium Event Thread Result: [I@59cf056b Database: sbtest Table: sbtest1
clickhouse-sink-connector-lt-1  | 2025-11-26 01:09:47.225 INFO  - ****** Acknowledging records ******
clickhouse-sink-connector-lt-1  | 2025-11-26 01:09:47.247 INFO  - ****** Thread: Sink connector Debezium Event Thread Batch Size: 2048 ******
clickhouse-sink-connector-lt-1  | 2025-11-26 01:09:47.255 INFO  - *** INSERT QUERY for Database(sbtest) ***: insert into `sbtest1`(`id`,`k`,`c`,`pad`,`_version`,`is_deleted`) select `id`,`k`,`c`,`pad`,`_version`,`is_deleted` from input('`id` Int32,`k` Int32,`c` String,`pad` String,`_version` UInt64,`is_deleted` UInt8')
clickhouse-sink-connector-lt-1  | 2025-11-26 01:09:47.311 INFO  - *************** EXECUTED BATCH Successfully Records: 2048************** task(0) Thread ID: Sink connector Debezium Event Thread Result: [I@7d60ab1 Database: sbtest Table: sbtest1
clickhouse-sink-connector-lt-1  | 2025-11-26 01:09:47.311 INFO  - ****** Acknowledgi

Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment

Labels

None yet

Projects

None yet

Development

Successfully merging this pull request may close these issues.

2 participants