canal1.1.1 ClientAdapter 同步到hbase报错java.lang.NullP
`2018-10-31 10:26:48.345 ERROR 5095 --- [ main] c.a.o.c.a.l.loader.CanalAdapterService : ## something goes wrong when starting up the canal client adapters:
java.lang.NullPointerException: null at com.alibaba.otter.canal.adapter.launcher.loader.CanalAdapterLoader.init(CanalAdapterLoader.java:61) ~[classes!/:na] at com.alibaba.otter.canal.adapter.launcher.loader.CanalAdapterService.init(CanalAdapterService.java:48) ~[classes!/:na] at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method) ~[na:1.8.0_73] at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62) ~[na:1.8.0_73] at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43) ~[na:1.8.0_73] at java.lang.reflect.Method.invoke(Method.java:497) ~[na:1.8.0_73] at org.springframework.beans.factory.annotation.InitDestroyAnnotationBeanPostProcessor$LifecycleElement.invoke(InitDestroyAnnotationBeanPostProcessor.java:365) [spring-beans-5.0.5.RELEASE.jar!/:5.0.5.RELEASE] at org.springframework.beans.factory.annotation.InitDestroyAnnotationBeanPostProcessor$LifecycleMetadata.invokeInitMethods(InitDestroyAnnotationBeanPostProcessor.java:308) [spring-beans-5.0.5.RELEASE.jar!/:5.0.5.RELEASE] at org.springframework.beans.factory.annotation.InitDestroyAnnotationBeanPostProcessor.postProcessBeforeInitialization(InitDestroyAnnotationBeanPostProcessor.java:135) [spring-beans-5.0.5.RELEASE.jar!/:5.0.5.RELEASE] at org.springframework.beans.factory.support.AbstractAutowireCapableBeanFactory.applyBeanPostProcessorsBeforeInitialization(AbstractAutowireCapableBeanFactory.java:422) [spring-beans-5.0.5.RELEASE.jar!/:5.0.5.RELEASE] at org.springframework.beans.factory.support.AbstractAutowireCapableBeanFactory.initializeBean(AbstractAutowireCapableBeanFactory.java:1694) [spring-beans-5.0.5.RELEASE.jar!/:5.0.5.RELEASE]`
修改了config/application.yml ,base/mytest_person2.yml ，启动了canal-deployer-1.1.1，deployer中的canal.serverMode=kafka，执行java -jar canal-adapter-launcher.jar报以上错误。
`[root@hadoop01 config]# cat application.yml server: port: 8081 logging: level: com.alibaba.otter.canal.client.adapter.hbase: DEBUG spring: jackson: date-format: yyyy-MM-dd HH:mm:ss time-zone: GMT+8 default-property-inclusion: non_null
hbasezookeeper.quorum: 127.0.0.1 hbase.zookeeper.property.clientPort: 2181 hbase.zookeeper.znode.parent: /hbase
canal.conf: canalServerHost: 127.0.0.1:11111
原提问者GitHub用户brightsong
写回答
-
你是用kafka模式, 不能用canalInstances模式接收数据, 把下面这段注释掉
canalInstances: - instance: example groups: - outAdapters: - name: logger - name: hbase properties: hbase.zookeeper.quorum: ${hbase.zookeeper.quorum} hbase.zookeeper.property.clientPort: ${hbase.zookeeper.property.clientPort} zookeeper.znode.parent: ${hbase.zookeeper.znode.parent}
从 mqTopics: 这里开始配置adapter
原回答者GitHub用户rewerma
2023-05-09 18:50:20赞同 展开评论 打赏
版权声明：本文内容由阿里云实名注册用户自发贡献，版权归原作者所有，阿里云开发者社区不拥有其著作权，亦不承担相应法律责任。具体规则请查看《阿里云开发者社区用户服务协议》和《阿里云开发者社区知识产权保护指引》。如果您发现本社区中有涉嫌抄袭的内容，填写侵权投诉表单进行举报，一经查实，本社区将立刻删除涉嫌侵权内容。
