alibaba / canal

阿里巴巴 MySQL binlog 增量订阅&消费组件
Apache License 2.0
28.4k stars 7.59k forks source link

canal adapter使用pulsar时报 deserializer failed Error sync and rollback, execute times #4610

Open liyeyong opened 1 year ago

liyeyong commented 1 year ago

environment

Issue Description

canal adapter 使用pulsar时消费消息报反序列失败

Steps to reproduce

Expected behaviour

Actual behaviour

com.alibaba.otter.canal.adapter.launcher.loader.AdapterProcessor#AdapterProcessor 72行 properties.put(CanalConstants.CANAL_MQ_FLAT_MESSAGE, canalClientConfig.getFlatMessage());

com.alibaba.otter.canal.connector.pulsarmq.consumer.CanalPulsarMQConsumer#init 107行 String flatMessageStr = properties.getProperty(CanalConstants.CANAL_MQ_FLAT_MESSAGE);

If there is an exception, please attach the exception trace:

Just put your stack trace here!
liyeyong commented 1 year ago

put boolean值进去,去用string接收