zhangyang

[ISSUE #3306] Implement SelectMessageQueueByMachineRoom

2

## What is the purpose of the change #3306 ## Brief changelog - Assign the expected message to be written to the computer room in consumeridcs, and confirm the machine...

Fix #144 - Records the current term of each node when the master node sends a heartbeat to the slave node. - Check whether the term of each node is...

As shown below: rocket-02: LEADER rocket-01: FOLLOWER rocket-03: CANDIDATE In rocket-03, the waterMark is empty, indicating that the node has changed from FOLLOWER to CANDIDATE. But the term of 03...

[rocketmq-connect] For replicator design ideas, seek advice.

5

After reading the code of rocketmq connect module, I have some questions to ask for advice. 1.The current usage of rocketmq-connect is that transferred to the middle tier by sourceTask,...

[rocketmq-replicator] Add RmqSinkTask

1

1. Please describe the feature you are requesting. - Provide RmqSinkTask, call RmqSinkTask in WorkerDirectTask to write data directly to the target cluster. 2. Provide any additional detail on your...

[rocketmq-connect] format converter

1

1. Please describe the issue you observed: - The converter logic is integrated with sendRecord, which is not conducive to subsequent expansion. 2. Other information (e.g. detailed explanation, logs, related...

[rocketmq-replicator] Realize consumption offset synchronization

3

1. Please describe the feature you are requesting. - Provide MetaSinkTask, call MetaSinkTask in WorkerDirectTask to write data directly to the target cluster. - In MetaSinkTask, the updateConsumeOffset method will...

[ISSUE #844] Realize consumption offset synchronization

2

## What is the purpose of the change https://github.com/apache/rocketmq-externals/issues/844 ## Brief changelog - Add MetaSinkTask. - Consistency check of consumption offset. ## Verifying this change XXXX Follow this checklist to...

[ISSUE #826] Add RmqSinkTask

1

## What is the purpose of the change https://github.com/apache/rocketmq-externals/issues/826 ## Brief changelog - Add RmqSinkTask. - RmqSourceTask adds schema field. ## Verifying this change - todo Follow this checklist to...

## What is the purpose of the change #829 ## Brief changelog - Abstract the converter logic into the corresponding Converter object. ## Verifying this change XXXX Follow this checklist...