Ling Jin

Question: what would happen if produce a mount of messages by an async Writer to a Kafka cluster without response？

2

**Describe the solution you'd like** A clear and concise description of what you want to happen. Consider the following steps * Use an async Writer to write messages to a...

AsyncProducer `Close` blocked for infinity

13

##### Versions *Please specify real version numbers or git SHAs, not just "Latest" since that changes fairly regularly.* | Sarama | Kafka | Go | |--------|-------|----| | 1.27.2 | 3.0.0...

Bug: cluster admin refresh medatadata report error when set `Metadata.Full` to false.

2

##### Versions When there is no topic in the Kafka cluster, metadata cannot be reported, if we set `Metadata.Full` to false. *Please specify real version numbers or git SHAs, not...

Is there anyone using this module in production?

4

We are taking the investigation into this module, and want to know more about it. Is there anyone using it in a real production environment, can you provide some useful...

etcd(cdc): refactor pd access method

4

### What problem does this PR solve? Issue Number: close #6614 ### What is changed and how it works? * refactor `pdutil` * fix etcd health check print too much...

[DNM] changefeed(ticdc): refactor new changefeed method attach the reactor directly

2

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

[DNM] logs(cdc): adjust logs in upstream and capture.

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...

processor(ticdc): refactor create processor method

6

### What problem does this PR solve? Issue Number: close #6726 ### What is changed and how it works? * when new the processor, attach the corresponding `changefeed` to it...

# Package organization * [x] introduce server interface and package #6358 * [x] reorganize the command directory #6364 * [x] #6726 * [x] #6761 * [x] #6972 # Remove dependency...