canal的INVALID_TOPIC_EXCEPTION问题

启动canal，canal.log存在INVALID_TOPIC_EXCEPTION问题

 [kafka-producer-network-thread | producer-2] WARN  org.apache.kafka.clients.NetworkClient - [Producer clientId=producer-2] Error while fetching metadata with correlation id 7168 : {=INVALID_TOPIC_EXCEPTION}

解决方案

canal instance.properties需要打开canal.mq.topic参数
canal.mq.topic 这一项最好不要注释,可以创建一个不适用的topic配置该项

# mq config
canal.mq.topic=xxxx

原因:如果有一些不符合dynamicTopic匹配的语句的消息会发送到该topic而避免报错 INVALID_TOPIC_EXCEPTION

canal的INVALID_TOPIC_EXCEPTION问题相关推荐

前端【vue】实现文档在线预览功能，在线预览pdf、word、xls、ppt等office文件
前端江太公前端实现文档在线预览功能最直接的就是使用XDOC 文档云服务 XDOC可以实现预览以DataURI表示的DOC文档,此外XDOC还可以实现文本.带参数文本.html文本.json文本.公 ...
MySQL 的 Binlog 日志处理工具（Canal/Maxwell/Databus/DTS）对比
点击上方蓝色"方志朋",选择"设为星标" 回复"666"获取独家整理的学习资料! Canal 定位:基于数据库增量日志解析,提供增量数据订阅 ...
MySQL增量订阅消费组件Canal POC
POC的目的: 1.与MYSQL的对接方式,配置文档 2.订阅的延迟 3.订阅后宕机消息会不会丢失 4.能不能从指定的点开始重新订阅 5.高并发写入的时候,日志的顺序是否还能保持,不考虑消费的情况订阅 ...
数据同步的终极解决方案，阿里巴巴开源的Canal框架当之无愧！！
写在前面在当今互联网行业,尤其是现在分布式.微服务开发环境下,为了提高搜索效率,以及搜索的精准度,会大量使用Redis.Memcached等NoSQL数据库,也会使用大量的Solr.Elastics ...
谈谈对 Canal（增量数据订阅与消费）的理解--大数据平台技术栈系列(3)
之前说了,大数据平台技术栈 (可点击查看),今天就来说说其中的Cannal 来源:朱小厮, blog.csdn.net/u013256816/article/details/52475190 概述 c ...
canal+mysql+rocket
版本 canal.deployer-1.1.5 canal.admin-1.1.5 rocketmq-all-4.9.3-bin-release rocketmq-deshboard-master m ...
canal下载 linux_canal实时同步mysql数据到redis或ElasticSearch
一.Canal架包下载上传 (一)下载官网架包地址为:https://github.com/alibaba/canal/releases/tag/canal-1.1.5-alpha-2 本人百度云盘 ...
基于数据库数据增量同步_基于canal实现分布式数据同步
应用场景分布式架构中,数据同步常常是个大问题.例如,mysql中的数据,可能在ElasticSearch有一份索引,在redis有一份缓存,在Nginx有一份缓存,这时候只要你修改了mysql中的数 ...
Canal安装说明(Windows版)
第一步: 从github上下载. https://github.com/alibaba/canal/releases/ 注:Mysql不用低于5.6,建议下载版本:v1.1.4,稳定些第二步: 开启 ...

canal的INVALID_TOPIC_EXCEPTION问题

启动canal，canal.log存在INVALID_TOPIC_EXCEPTION问题

解决方案

canal的INVALID_TOPIC_EXCEPTION问题相关推荐

最新文章

热门文章