NiFi 示例将 MySQL 中数据导出并转换为 JSON 发送到 Kafka

添加 ExecuteSQL 处理器 添加 ExecuteSQL 到面板 配置 ExecuteSQL 配置 DBCPConnectionPool 更改 DBCPConnectionPool 配置,直到将 state 从 Invalid 变为 Disable 数据库连接池配置信息 启用 DBCPConnectionPool 任务成功或失败时的处理方式 . 添加 ConvertAvroToJSON 处理
相关文章
相关标签/搜索