开发者社区> 问答> 正文

ClientAdapter(HBase), HBase 关闭再启动后,clientAdapter 不

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

展开
收起
数据大拿 2023-05-04 11:56:18 117 0
1 条回答
写回答
取消 提交回答
  • 可能是hbase断线重连失败了,无法获得connection,mq消费一直阻塞在那

    原回答者GitHub用户rewerma

    2023-05-05 10:26:06
    赞同 展开评论 打赏
问答排行榜
最热
最新

相关电子书

更多
大数据时代的存储 ——HBase的实践与探索 立即下载
Hbase在滴滴出行的应用场景和最佳实践 立即下载
阿里云HBase主备双活 立即下载