无法过滤事务信息TRANSACTIONBEGIN

[DataDevs]

canal1.1.3版本
canal.instance.filter.transaction.entry = true
canal.mq.flatMessage = false
canal.serverMode = kafka
无法过滤掉TRANSACTIONBEGIN TRANSACTIONEND信息

调试的时候记录了一些信息
在CanalMQStarter的start中 获取到的System.getProperty("canal.instance.filter.transaction.entry") 都是true
但是在MessageSerializer 中获取System.getProperty("canal.instance.filter.transaction.entry")却是false
在CanalMessageSerializer的serializer中的if (!CollectionUtils.isEmpty(data.getEntries()))代码块中filterTransactionEntry也是false
所以一直没有走到continue;这个段代码

[DataDevs]

从CanalStater的start来看，是先实例化CanalKafkaProducer 再实例化CanalMQStarter
在CanalMQStarter的start中 才会
if (properties.isFilterTransactionEntry()) {
System.setProperty("canal.instance.filter.transaction.entry", "true");
}
而isFilterTransactionEntry一直为true，setFilterTransactionEntry没有被调用过