zhoubo comments

Results 16 comments of


                                            zhoubo

use the StringBuilder another method can reduce impact on array copy performance

Please submit an issue first, this pr is associated with this issue

Use constants or objects with specific values to call equals

Please submit an issue first, pr associate this issue

[ISSUE #3231]add topic expire time policy

Please resolve the branch conflict

[rocketmq-replicator] RmqMetaReplicator Initialize DefaultMQAdminExt exception

rocketmq-connect already has an independent repository, you can go to this repository to submit PR, issue. https://github.com/apache/rocketmq-connect

[ISSUE #844] Realize consumption offset synchronization

In my opinion, replicator is unique when it is used because its source and target are RocketMQ. In replicator's implementation, messages are consumed by consumers and sent by Runtime producer....

[rocketmq-replicator] Realize consumption offset synchronization

rocketmq-connect already has an independent repository, you can go to this repository to submit PR, issue. https://github.com/apache/rocketmq-connect

[rocketmq-connect] Synchronize data from Mysql to Redis

@githublaohu rocketmq-connect already has an independent repository, you can go to this repository to submit PR, issue. https://github.com/apache/rocketmq-connect

[rocketmq-replicator] Add RmqSinkTask

rocketmq-connect already has an independent repository, you can go to this repository to submit PR, issue. https://github.com/apache/rocketmq-connect

RocketMQSink(KeyValueSerializationSchema<IN> schema, TopicSelector<IN> topicSelector, Properties props) missing in master branch

Please follow the issue guidelines to clearly describe your issue.

The larger the number of Connector Topic read and write queues, the slower the consumption

Please follow the issue guidelines to clearly describe your issue.