client-adapter canal.conf 不需要配置canal-server instan
client-adapter canal.conf 不需要配置canal-server instance的用户名和密码吗?
public class CanalAdapterWorker extends AbstractCanalAdapterWorker {
private static final int BATCH_SIZE = 50; private static final int SO_TIMEOUT = 0;
private CanalConnector connector;
/** * 单台client适配器worker的构造方法 * * @param canalDestination canal实例名 * @param address canal-server地址 * @param canalOuterAdapters 外部适配器组 */ public CanalAdapterWorker(CanalClientConfig canalClientConfig, String canalDestination, SocketAddress address, List<List> canalOuterAdapters){ super(canalOuterAdapters); this.canalClientConfig = canalClientConfig; this.canalDestination = canalDestination; connector = CanalConnectors.newSingleConnector(address, canalDestination, "", "");
connector = CanalConnectors.newSingleConnector(address, canalDestination, "", ""); 这里username和password为"",
原提问者GitHub用户bigkun
写回答
-
要不你就定义一个变量 要不直接把那个username password放进去 要不就写死
最新代码已经修复
原回答者GitHub用户agapple
2023-05-04 15:42:58赞同 展开评论 打赏
版权声明：本文内容由阿里云实名注册用户自发贡献，版权归原作者所有，阿里云开发者社区不拥有其著作权，亦不承担相应法律责任。具体规则请查看《阿里云开发者社区用户服务协议》和《阿里云开发者社区知识产权保护指引》。如果您发现本社区中有涉嫌抄袭的内容，填写侵权投诉表单进行举报，一经查实，本社区将立刻删除涉嫌侵权内容。
