1、使用rocketMQ方式, 正常启动HBase和2、clientAdapter可以正常写入
HBase 关闭再启动后(重启),clientAdapter 不能写入数据,log持续打日志:
2019-07-09 16:37:47.032 [ConsumeMessageThread_18] INFO c.a.otter.canal.client.rocketmq.RocketMQCanalConnector - Get Message:[MessageExt [queueId=0, storeSize=995, queueOffset=498371, sysFlag=0, bornTimestamp=1562660306704, bornHost=/192.168.1.82:35231, storeTimestamp=1562660306704, storeHost=/192.168.1.82:10911, msgId=C0A8015200002A9F0000000029398BEB, commitLogOffset=691637227, bodyCRC=1016478093, reconsumeTimes=20, preparedTransactionOffset=0, toString()=Message [topic=example, flag=0, properties={MIN_OFFSET=0, MAX_OFFSET=498372, UNIQ_KEY=C0A80152151C5FD0D5AE2CB2AB10A865, WAIT=true}, body=845]], MessageExt [queueId=0, storeSize=1056, queueOffset=498372, sysFlag=0, bornTimestamp=1562660306704, bornHost=/192.168.1.82:35231, storeTimestamp=1562660306705, storeHost=/192.168.1.82:10911, msgId=C0A8015200002A9F0000000029398FCE, commitLogOffset=691638222, bodyCRC=69929417, reconsumeTimes=19, preparedTransactionOffset=0, toString()=Message [topic=example, flag=0, properties={MIN_OFFSET=0, MAX_OFFSET=498373, UNIQ_KEY=C0A80152151C5FD0D5AE2CB2AB10A866, WAIT=true}, body=906]], MessageExt [queueId=0, storeSize=1038, queueOffset=498373, sysFlag=0, bornTimestamp=1562660306705, bornHost=/192.168.1.82:35231, storeTimestamp=1562660306705, storeHost=/192.168.1.82:10911, msgId=C0A8015200002A9F00000000293993EE, commitLogOffset=691639278, bodyCRC=1481139005, reconsumeTimes=19, preparedTransactionOffset=0, toString()=Message [topic=example, flag=0, properties={MIN_OFFSET=0, MAX_OFFSET=498374, UNIQ_KEY=C0A80152151C5FD0D5AE2CB2AB11A867, WAIT=true}, body=888]], MessageExt [queueId=0, storeSize=1056, queueOffset=498374, sysFlag=0, bornTimestamp=1562660306806, bornHost=/192.168.1.82:35231, storeTimestamp=1562660306806, storeHost=/192.168.1.82:10911, msgId=C0A8015200002A9F00000000293997FC, commitLogOffset=691640316, bodyCRC=2071340091, reconsumeTimes=19, preparedTransactionOffset=0, toString()=Message [topic=example, flag=0, properties={MIN_OFFSET=0, MAX_OFFSET=498375, UNIQ_KEY=C0A80152151C5FD0D5AE2CB2AB76A868, WAIT=true}, body=906]], 单条日志非常长
原提问者GitHub用户elfc
版权声明:本文内容由阿里云实名注册用户自发贡献,版权归原作者所有,阿里云开发者社区不拥有其著作权,亦不承担相应法律责任。具体规则请查看《阿里云开发者社区用户服务协议》和《阿里云开发者社区知识产权保护指引》。如果您发现本社区中有涉嫌抄袭的内容,填写侵权投诉表单进行举报,一经查实,本社区将立刻删除涉嫌侵权内容。