无法连接到NiFi中的binlog客户端
Unable to connect to the binlog client in NiFi
我正在构建一个 NiFi dadaflow,我需要从 MySql 数据库获取数据更改,所以我想使用 CaptureChangeMySQL 处理器来完成。
当我 运行 CaptureChangeMySQL 处理器时出现以下错误,但我看不出是什么原因造成的:
Failed to process session due to Could not connect binlog client to any of the specified hosts due to: BinaryLogClient was unable to connect in 10000ms: org.apache.nifi.processor.exception.ProcessException: Could not connect binlog client to any of the specified hosts due to: BinaryLogClient was unable to connect in 10000ms
我启用了以下控制器服务:
- DistributedMapCacheClientService
- 分布式地图缓存服务器
但我不确定它们是否配置正确:
DistributedMapCacheServer properties
DistributedMapCacheClientService properties
在 MySql 中,我启用了 log_bin 变量,默认情况下它没有。我检查了一下,确实有一些数据变化时创建的binlog文件。
所以我认为问题在于控制器服务及其连接方式,我不清楚。
我搜索了有关如何使用此 NiFi 处理器的教程,但找不到如何修复此错误。我主要看这个:https://community.hortonworks.com/articles/113941/change-data-capture-cdc-with-apache-nifi-version-1-1.html 但它对我没有帮助。
有没有人已经用这个处理器做CDC了?
提前谢谢你。
我发现出了什么问题:我试图连接到 CaptureChangeMySQL 处理器的 MySQL 主机的错误端口:x
我正在构建一个 NiFi dadaflow,我需要从 MySql 数据库获取数据更改,所以我想使用 CaptureChangeMySQL 处理器来完成。
当我 运行 CaptureChangeMySQL 处理器时出现以下错误,但我看不出是什么原因造成的:
Failed to process session due to Could not connect binlog client to any of the specified hosts due to: BinaryLogClient was unable to connect in 10000ms: org.apache.nifi.processor.exception.ProcessException: Could not connect binlog client to any of the specified hosts due to: BinaryLogClient was unable to connect in 10000ms
我启用了以下控制器服务:
- DistributedMapCacheClientService
- 分布式地图缓存服务器
但我不确定它们是否配置正确:
DistributedMapCacheServer properties
DistributedMapCacheClientService properties
在 MySql 中,我启用了 log_bin 变量,默认情况下它没有。我检查了一下,确实有一些数据变化时创建的binlog文件。
所以我认为问题在于控制器服务及其连接方式,我不清楚。
我搜索了有关如何使用此 NiFi 处理器的教程,但找不到如何修复此错误。我主要看这个:https://community.hortonworks.com/articles/113941/change-data-capture-cdc-with-apache-nifi-version-1-1.html 但它对我没有帮助。
有没有人已经用这个处理器做CDC了?
提前谢谢你。
我发现出了什么问题:我试图连接到 CaptureChangeMySQL 处理器的 MySQL 主机的错误端口:x