Apache Nifi可以检测数据库表记录的变化，并通过使用CaptureChangeMySQL和CaptureChangePostgreSQL处理器来实现。下面是一个使用CaptureChangeMySQL处理器的示例解决方案：

1. 配置CaptureChangeMySQL处理器：

   • 将CaptureChangeMySQL处理器添加到Nifi工作流中。
   • 在处理器配置中，设置数据库连接属性，如数据库URL、用户名和密码。
   • 配置要监视的数据库表，可以选择特定的表、模式或数据库。
   • 配置输出队列以接收捕获的变化事件。

2. 配置处理变化事件的处理器：

   • 添加一个处理器来处理从CaptureChangeMySQL处理器接收到的变化事件。可以使用EvaluateJsonPath、SplitJson和其他处理器来处理变化事件。

3. 示例代码：

   • 在处理变化事件的处理器中，可以使用Groovy脚本来处理和操作变化事件。下面是一个示例Groovy脚本，可以解析变化事件的JSON，并提取重要的字段：

   import groovy.json.JsonSlurper
   
   def flowFile = session.get()
   if (!flowFile) return
   
   def jsonContent = flowFile.getAttribute('json')
   def jsonSlurper = new JsonSlurper()
   def jsonObject = jsonSlurper.parseText(jsonContent)
   
   def id = jsonObject.id
   def name = jsonObject.name
   def changes = jsonObject.changes
   
   // 在这里可以对变化事件进行处理和操作
   
   flowFile = session.putAttribute(flowFile, 'id', id)
   flowFile = session.putAttribute(flowFile, 'name', name)
   flowFile = session.putAttribute(flowFile, 'changes', changes)
   
   session.transfer(flowFile, REL_SUCCESS)
   

   • 在上面的代码中，我们使用JsonSlurper解析变化事件的JSON，并提取id、name和changes字段。然后，我们可以根据需要对变化事件进行进一步的处理和操作。

这是一个使用CaptureChangeMySQL处理器和Groovy脚本来检测数据库表记录变化的解决方案。你可以根据实际需求进行调整和扩展。