1.1.3 投递到kafka 不会自动创建topic。canal.log 错误如下

环境信息

canal version 1.1.3 mysql version 5.7

问题描述

2019-02-19 17:19:43.065 [pool-4-thread-1] ERROR com.alibaba.otter.canal.server.CanalMQStarter - batchId:462 is not the firstly:2 com.alibaba.otter.canal.meta.exception.CanalMetaManagerException: batchId:462 is not the firstly:2 2019-02-19 17:19:43.065 [pool-4-thread-1] ERROR com.alibaba.otter.canal.server.CanalMQStarter - batchId:462 is not the firstly:2 com.alibaba.otter.canal.meta.exception.CanalMetaManagerException: batchId:462 is not the firstly:2 2019-02-19 17:25:07.766 [pool-4-thread-1] ERROR com.alibaba.otter.canal.server.CanalMQStarter - batchId:486 is not the firstly:2 com.alibaba.otter.canal.meta.exception.CanalMetaManagerException: batchId:486 is not the firstly:2 2019-02-19 17:25:07.766 [pool-4-thread-1] ERROR com.alibaba.otter.canal.server.CanalMQStarter - batchId:486 is not the firstly:2 com.alibaba.otter.canal.meta.exception.CanalMetaManagerException: batchId:486 is not the firstly:2 2019-02-19 17:30:27.956 [pool-4-thread-1] ERROR com.alibaba.otter.canal.server.CanalMQStarter - batchId:509 is not the firstly:2 com.alibaba.otter.canal.meta.exception.CanalMetaManagerException: batchId:509 is not the firstly:2 2019-02-19 17:30:27.956 [pool-4-thread-1] ERROR com.alibaba.otter.canal.server.CanalMQStarter - batchId:509 is not the firstly:2 com.alibaba.otter.canal.meta.exception.CanalMetaManagerException: batchId:509 is not the firstly:2 2019-02-19 17:32:29.863 [pool-4-thread-1] ERROR com.alibaba.otter.canal.server.CanalMQStarter - batchId:519 is not the firstly:2 com.alibaba.otter.canal.meta.exception.CanalMetaManagerException: batchId:519 is not the firstly:2 2019-02-19 17:32:29.863 [pool-4-thread-1] ERROR com.alibaba.otter.canal.server.CanalMQStarter - batchId:519 is not the firstly:2 com.alibaba.otter.canal.meta.exception.CanalMetaManagerException: batchId:519 is not the firstly:2 2019-02-19 17:32:45.077 [pool-4-thread-1] ERROR com.alibaba.otter.canal.server.CanalMQStarter - batchId:521 is not the firstly:2 com.alibaba.otter.canal.meta.exception.CanalMetaManagerException: batchId:521 is not the firstly:2 2019-02-19 17:32:45.077 [pool-4-thread-1] ERROR com.alibaba.otter.canal.server.CanalMQStarter - batchId:521 is not the firstly:2 com.alibaba.otter.canal.meta.exception.CanalMetaManagerException: batchId:521 is not the firstly:2 2019-02-19 17:33:40.227 [pool-4-thread-1] ERROR com.alibaba.otter.canal.server.CanalMQStarter - batchId:526 is not the firstly:2 com.alibaba.otter.canal.meta.exception.CanalMetaManagerException: batchId:526 is not the firstly:2 2019-02-19 17:33:40.227 [pool-4-thread-1] ERROR com.alibaba.otter.canal.server.CanalMQStarter - batchId:526 is not the firstly:2 com.alibaba.otter.canal.meta.exception.CanalMetaManagerException: batchId:526 is not the firstly:2 2019-02-19 18:37:08.489 [pool-4-thread-1] ERROR com.alibaba.otter.canal.server.CanalMQStarter - batchId:794 is not the firstly:2 com.alibaba.otter.canal.meta.exception.CanalMetaManagerException: batchId:794 is not the firstly:2 2019-02-19 18:37:08.489 [pool-4-thread-1] ERROR com.alibaba.otter.canal.server.CanalMQStarter - batchId:794 is not the firstly:2 com.alibaba.otter.canal.meta.exception.CanalMetaManagerException: batchId:794 is not the firstly:2

dynamicTopic配置如下： canal.mq.dynamicTopic= .\..*

kafka auto.create.topics.enable=true

原提问者GitHub用户WhatisAnt