如何使用nifi capturechangemysql?

vc6uscn9  于 2021-05-27  发布在  Hadoop
关注(0)|答案(1)|浏览(580)

导言

我有一个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

nifi capturechangemysql配置

nifi cdc mapcache配置(分布式Map缓存客户端服务)

nifi分布式Map缓存服务器配置


在这种配置下,我的capturechange处理器什么都不做(至少什么都看不见)。我做错了什么阻止我使用它?

frebpwbc

frebpwbc1#

在你的 my.cnf 文件,你设置了 binlog_do_db = source . binlog-do-db 使指定数据库的主只写语句进入其二进制日志。在您的情况下,它应该设置为test。
参考MySQL5.7 binlog do db=db\u name

相关问题