lizhimins commented on issue #6977: URL: https://github.com/apache/rocketmq/issues/6977#issuecomment-1621359483
从描述看像是客户端逻辑的问题，没有选择备节点。不过基于低版本的 flink connector 的线程模型和实现存在诸多问题，我已经基于 FLIP-27/191 重构了 connector 的实现，这几天应该会提交到社区，欢迎 review 和指点。 From the description, it seems like a client-side logic issue where no backup broker was selected. However, there are many issues with the thread model and implementation of the low version Flink connector. Therefore, I have refactored the connector's implementation based on FLIP-27/191 and will be submitting it to the community in the next few days. I welcome reviews and suggestions. -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail: [email protected] For queries about this service, please contact Infrastructure at: [email protected]
