nhsmw

ticdc: fix detecting kafka version

2

### What problem does this PR solve? Issue Number: close #11047 ### What is changed and how it works? Expose `requestVersion` param and use the low version by default. After...

[DNM] sink(ticdc): limit kafka producer

3

### What problem does this PR solve? Issue Number: close #xxx ### What is changed and how it works? ### Check List #### Tests - Unit test - Integration test...

sink(ticdc): reduce redundant log

2

### What problem does this PR solve? Issue Number: close #11220 ### What is changed and how it works? As title. ### Check List #### Tests - Unit test -...

sink(ticdc): redundant log

1

### What did you do? run cluster and create a changefeed run kafka consumer ### What did you expect to see? necessary log ### What did you see instead? redundant...

[bitnami/kafka] Kafka image restart in K8s

8

### Name and Version bitnami/kafka:v2.0.0 ### What architecture are you using? None ### What steps will reproduce the bug? start a kafka service in K8s ### What is the expected...

sink(ticdc): DDL event support for the Debezium protocol

2

### What problem does this PR solve? Issue Number: close #11566 ### What is changed and how it works? Debezium provides the SQL CREATE, ALTER, or DROP statement that results...

eventFilter incorrectly affects update events

3

### What did you do? 1. create a changefeed with config ``` [filter] rules = ['test.*'] [[filter.event-filters]] matcher = ['test.t'] ignore-event = ["delete"] # filter out delete event of table...

sink(ticdc): modify mysql sink config

3

### What problem does this PR solve? Issue Number: close #11558 ### What is changed and how it works? As title. ### Check List #### Tests - Manual test (add...

metric(cdc): fix uncorrect metric WorkerBusyRatio

2

### What problem does this PR solve? Issue Number: close #11664 ### What is changed and how it works? 1. Update worker_busy_ratio calculation. 2. Split redo metrics by log type....

kafka(ticdc): fix kafka consumer doesn't check partition and old message

8

### What problem does this PR solve? Issue Number: close #11482 ### What is changed and how it works? Add partition check and old message check about simple protocol ###...