问题描述

介绍

我有一个接收定期更新的 mysql 数据库。我想定期检查这个 mysql 数据库以了解 Nifi 的变化。

为此，CaptureChangeMySQL 处理器似乎很完美。

但是，我无法使其工作。

我按照本教程进行操作，但是在从数据库中插入/删除行时，处理器没有捕获任何内容。

设置

一个本地 MySQL，可在 localhost:3306 访问
同一台机器上的一个 nifi。

MySQL 配置

它有一个以表命名的数据库test，device其中包含超过 20k 行。

我的my.cnf文件/etc/mysql/如下：

#
# The MySQL database server configuration file.
#
# You can copy this to one of:
# - "/etc/mysql/my.cnf" to set global options,
# - "~/.my.cnf" to set user-specific options.
# 
# One can use all long options that the program supports.
# Run program with --help to get a list of available options and with
# --print-defaults to see which it would actually understand and use.
#
# For explanations see
# http://dev.mysql.com/doc/mysql/en/server-system-variables.html

#
# * IMPORTANT: Additional settings that can override those from this file!
#   The files must end with '.cnf', otherwise they'll be ignored.
#

!includedir /etc/mysql/conf.d/
!includedir /etc/mysql/mysql.conf.d/
[mysqld]
server_id = 1
log_bin = delta
binlog_format=row
binlog_do_db = source