NiFi 示例將 MySQL 中數據導出並轉換爲 JSON 發送到 Kafka

添加 ExecuteSQL 處理器 添加 ExecuteSQL 到面板 配置 ExecuteSQL 配置 DBCPConnectionPool 更改 DBCPConnectionPool 配置，直到將 state 從 Invalid 變爲 Disable 數據庫連接池配置信息 啓用 DBCPConnectionPool 任務成功或失敗時的處理方式 . 添加 ConvertAvroToJSON 處理

>>阅读原文<<