8000 1198 compressed binlog history by subkanthi · Pull Request #1199 · Altinity/clickhouse-sink-connector · GitHub
[go: up one dir, main page]
Skip to content

1198 compressed binlog history - #1199

Merged
subkanthi merged 4 commits into
2.8.1from
1198-compressed-binlog-history
Dec 3, 2025
Merged

1198 compressed binlog history#1199
subkanthi merged 4 commits into
2.8.1from
1198-compressed-binlog-history

Conversation

@subkanthi
@subkanthi subkanthi commented Nov 26, 2025
Copy link
Copy Markdown
Collaborator

closes: #1198

@subkanthi
subkanthi commented Nov 26, 2025
Copy link
Copy Markdown
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

@subkanthi
subkanthi merged commit b0505f0 into 2.8.1 Dec 3, 2025
7 checks passed
@subkanthi
subkanthi deleted the 1198-compressed-binlog-history branch December 3, 2025 00:25
@subkanthi subkanthi mentioned this pull request Feb 12, 2026
Open
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment

Reviewers

No reviews

Assignees

No one assigned

Labels

None yet

Projects

None yet

Milestone

No milestone

Development

Successfully merging this pull request may close these issues.

1 participant

@subkanthi
0