我正在构建一个 NiFi dadaflow，并且需要从 MySql 数据库获取数据更改，因此我想使用 CaptureChangeMySQL 处理器来执行此操作。
当我运行 CaptureChangeMySQL 处理器时，出现以下错误，但我不明白是什么原因导致的:
由于无法将 binlog 客户端连接到任何指定主机而无法处理 session ，原因是:BinaryLogClient 无法在 10000 毫秒内连接:org.apache.nifi.processor.exception.ProcessException:无法连接 binlog客户端连接到任何指定的主机，原因是:BinaryLogClient 无法在 10000 毫秒内连接
我启用了以下 Controller 服务:
- 分布式MapCacheClientService
- 分布式MapCacheServer
但我不确定它们是否配置正确:
DistributedMapCacheServer properties
DistributedMapCacheClientService properties
在 MySql 中，我启用了 log_bin 变量，默认情况下它没有启用。我查了一下，确实有一些数据变化时创建的binlog文件。
所以我认为问题在于 Controller 服务以及它们如何连接，我不清楚。
我搜索了有关如何使用此 NiFi 处理器的教程，但找不到如何修复此错误。我主要看的是这个:https://community.hortonworks.com/articles/113941/change-data-capture-cdc-with-apache-nifi-version-1-1.html但这对我没有帮助。
有人已经使用此处理器进行 CDC 了吗？
提前谢谢您。
最佳答案
我发现出了什么问题:我试图连接到 CaptureChangeMySQL 处理器的 MySQL 主机的错误端口:x
关于mysql - NiFi中无法连接binlog客户端，我们在Stack Overflow上找到一个类似的问题： https://stackoverflow.com/questions/56240317/