elegance code
Results
1
comments of
elegance code
rocketmq 模式下，这个 "canal.mq.enableDynamicQueuePartition=true" 参数应该是自动获取目标topic 的队列数量，但是未发送过消息，缓存中没有队列数，就会报空指针错误，除非设置 canal.mq.partitionsNum ，这样会语义不明，前面明确了动态获取。另外手工设置队列数可能不对，会导致第一次发送的消息未正确hash到预期的队列，继而影响顺序。 @agapple