canal與hbase的protobuf版本衝突

java.lang.UnsupportedOperationException: This is supposed to be overridden by subclasses.
	at com.google.protobuf.GeneratedMessage.getUnknownFields(GeneratedMessage.java:180)
	at com.alibaba.otter.canal.protocol.CanalPacket$ClientAuth.getSerializedSize(CanalPacket.java:2045)
	at com.google.protobuf.AbstractMessageLite.toByteString(AbstractMessageLite.java:49)
	at com.alibaba.otter.canal.client.impl.SimpleCanalConnector.doConnect(SimpleCanalConnector.java:150)
	at com.alibaba.otter.canal.client.impl.SimpleCanalConnector.connect(SimpleCanalConnector.java:97)
	at com.alibaba.otter.canal.client.CanalConnector$connect.call(Unknown Source)

測試環境:canal server和client版本:v1.0.22;hbase-client版本:1.0.1.1java

報錯緣由:canal 1.0.22版本依賴的protobuf版本爲2.4.1,hbase依賴的protobuf版本爲2.5.0,存在衝突。canal客戶端鏈接canal server時,客戶端classloader加載的版本爲2.5.0,而服務端protobuf版本爲2.4.1,致使請求報錯。git

解決方法:canal的protobuf版本升級爲2.5.0。github

步驟:從新生成protobuf java文件,並替換protocol/src/main/java/com/alibaba/otter/canal/protocol/;從新打canal-protocol包,替換client和server的canal-protocol依賴。測試

java文件拷貝:https://github.com/chaopengio/canal/tree/canal-1.0.21-protobuf-2.5.0/protocol/src/main/java/com/alibaba/otter/canal/protocolgoogle

參考:https://github.com/alibaba/canal/issues/125code

相關文章
相關標籤/搜索