Removed NiFi processors
Learn about the NiFi processors removed in this release of Cloudera Data Flow and the alternatives you can replace them with.
| Removed processor | Replace it with |
|---|---|
| ConsumeKafka_1_0 | ConsumeKafka2CDP, ConsumeKafka_2_6 |
| ConsumeKafka_2_0 | ConsumeKafka2CDP, ConsumeKafka_2_6 |
| ConsumeKafkaRecord_1_0 | ConsumeKafka2RecordCDP, ConsumeKafkaRecord_2_6 |
| ConsumeKafkaRecord_2_0 | ConsumeKafka2RecordCDP, ConsumeKafkaRecord_2_6 |
| ConvertAvroSchema | ConvertRecord |
| ConvertAvroToORC | ConvertRecord |
| ConvertCSVToAvro | ConvertRecord |
| ConvertJSONToAvro | ConvertRecord |
| ExecuteFlumeSink | None If this processor is required, you must use a NiFi Runtime version lower than 1.25.0.2.3.13.0-36. |
| ExecuteFlumeSource | None If this processor is required, you must use a NiFi Runtime version lower than 1.25.0.2.3.13.0-36. |
| GetIgniteCache | None If this processor is required, you must use a NiFi Runtime version lower than 1.25.0.2.3.13.0-36. |
| InferAvroSchema | ExtractSchemaRecord |
| PublishKafka_1_0 | PublishKafka_2_6 |
| PublishKafka_2_0 | PublishKafka2CDP, PublishKafka_2_6 |
| PublishKafkaRecord_1_0 | PublishKafka2RecordCDP, PublishKafkaRecord_2_6 |
| PublishKafkaRecord_2_0 | PublishKafka2RecordCDP, PublishKafkaRecord_2_6 |
| PutHive_1_1QL | PutClouderaHiveQL |
| PutHiveQL | PutClouderaHiveQL |
| PutHiveStreaming | PutClouderaHiveStreaming |
| PutIgniteCache | None If this processor is required, you must use a NiFi Runtime version lower than 1.25.0.2.3.13.0-36. |
| SelectHive_1_1QL | SelectClouderaHiveQL |
| SelectHiveQL | SelectClouderaHiveQL |
| StoreInKiteDataset | None If this processor is required, you must use a NiFi Runtime version lower than 1.25.0.2.3.13.0-36. |
| UpdateHive_1_1Table | UpdateClouderaHiveTable |
| UpdateHiveTable | UpdateClouderaHiveTable |
